kartothek.io.testing.update module

kartothek.io.testing.update.test_metadata_version(store_factory, bound_update_dataset, mock_default_metadata_version, backend_identifier)

kartothek.io.testing.update.test_partition_on_null(store_factory, bound_update_dataset)

kartothek.io.testing.update.test_raises_on_invalid_input(store_factory, bound_update_dataset)

kartothek.io.testing.update.test_raises_on_new_index_creation(backend_identifier, store_factory, bound_update_dataset, define_indices_on_partition)

kartothek.io.testing.update.test_schema_check_update(dfs, ok, store_factory, bound_update_dataset)

kartothek.io.testing.update.test_sort_partitions_by(store_factory, metadata_version, frozen_time_em, bound_update_dataset)

kartothek.io.testing.update.test_update_dataset_with_partitions__reducer(store_factory, metadata_version, bound_update_dataset, mocker, store)

kartothek.io.testing.update.test_update_dataset_with_partitions__reducer_delete_only(store_factory, metadata_version, frozen_time_em, bound_update_dataset, store)

kartothek.io.testing.update.test_update_dataset_with_partitions__reducer_nonexistent(store_factory, metadata_version, frozen_time_em, bound_update_dataset, store)

kartothek.io.testing.update.test_update_dataset_with_partitions__reducer_partitions(store_factory, frozen_time_em, bound_update_dataset)

kartothek.io.testing.update.test_update_dataset_with_partitions_alternative_name(bound_update_dataset, store, dataset_alternative_table_name, store_factory, dataset_factory_alternative_table_name, alternative_table_name)

kartothek.io.testing.update.test_update_dataset_with_partitions_no_index_input_info(store_factory, metadata_version, bound_update_dataset, store)

kartothek.io.testing.update.test_update_first_time_with_secondary_indices(store_factory, bound_update_dataset, define_indices_on_partition)

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)

kartothek.io.testing.update.test_update_raises_incompatible_inidces(store_factory, bound_update_dataset, df_not_nested)

kartothek.io.testing.update.test_update_raises_incompatible_partition_keys(store_factory, bound_update_dataset, df_not_nested)

kartothek.io.testing.update.test_update_secondary_indices_subset(store_factory, bound_update_dataset)