kartothek.io.testing.update module

kartothek.io.testing.update.test_metadata_version(store_factory, bound_update_dataset, mock_default_metadata_version, backend_identifier)[source]
kartothek.io.testing.update.test_partition_on_null(store_factory, bound_update_dataset)[source]
kartothek.io.testing.update.test_raises_on_invalid_input(store_factory, bound_update_dataset)[source]
kartothek.io.testing.update.test_raises_on_new_index_creation(backend_identifier, store_factory, bound_update_dataset, define_indices_on_partition)[source]
kartothek.io.testing.update.test_schema_check_update(dfs, ok, store_factory, bound_update_dataset)[source]
kartothek.io.testing.update.test_sort_partitions_by(store_factory, metadata_version, frozen_time_em, bound_update_dataset)[source]
kartothek.io.testing.update.test_update_dataset_with_partitions__reducer(store_factory, metadata_version, bound_update_dataset, mocker, store)[source]
kartothek.io.testing.update.test_update_dataset_with_partitions__reducer_delete_only(store_factory, metadata_version, frozen_time_em, bound_update_dataset, store)[source]
kartothek.io.testing.update.test_update_dataset_with_partitions__reducer_nonexistent(store_factory, metadata_version, frozen_time_em, bound_update_dataset, store)[source]
kartothek.io.testing.update.test_update_dataset_with_partitions__reducer_partitions(store_factory, frozen_time_em, bound_update_dataset)[source]
kartothek.io.testing.update.test_update_dataset_with_partitions_no_index_input_info(store_factory, metadata_version, bound_update_dataset, store)[source]
kartothek.io.testing.update.test_update_first_time_with_secondary_indices(store_factory, bound_update_dataset, define_indices_on_partition)[source]

Check it is possible to create a new dataset with indices defined either on partition or using the secondary_indices kwarg. The intention of this test is to verify that there are no exceptions raised related to index validation when a dataset is created using an update function

kartothek.io.testing.update.test_update_infers_partition_on(store_factory, bound_update_dataset, df_not_nested)[source]
kartothek.io.testing.update.test_update_raises_incompatible_inidces(store_factory, bound_update_dataset, df_not_nested)[source]
kartothek.io.testing.update.test_update_raises_incompatible_partition_keys(store_factory, bound_update_dataset, df_not_nested)[source]