kartothek.io.testing.extend_cube module

kartothek.io.testing.extend_cube.existing_cube(function_store)[source]
kartothek.io.testing.extend_cube.test_compression_is_compatible_on_extend_cube(driver, function_store)[source]

Test that partitons written with different compression algorithms are compatible

The compression algorithms are not parametrized because their availability depends on the arrow build. ‘SNAPPY’ and ‘GZIP’ are already assumed to be available in parts of the code. A fully parametrized test would also increase runtime and test complexity unnecessarily.

kartothek.io.testing.extend_cube.test_fail_all_empty(driver, function_store, existing_cube)[source]

Might happen due to DB-based filters.

kartothek.io.testing.extend_cube.test_fail_no_store_factory(driver, function_store, existing_cube, skip_eager)[source]
kartothek.io.testing.extend_cube.test_fail_not_a_df(driver, function_store, existing_cube)[source]

Pass some weird objects in.

kartothek.io.testing.extend_cube.test_fail_wrong_dataset_ids(driver, function_store, existing_cube, skip_eager, driver_name)[source]
kartothek.io.testing.extend_cube.test_fails_incompatible_dtypes(driver, function_store, existing_cube)[source]

Should also cross check w/ seed dataset.

kartothek.io.testing.extend_cube.test_fails_metadata_nested_wrong_type(driver, function_store, existing_cube)[source]
kartothek.io.testing.extend_cube.test_fails_metadata_unknown_id(driver, function_store, existing_cube)[source]
kartothek.io.testing.extend_cube.test_fails_metadata_wrong_type(driver, function_store, existing_cube)[source]
kartothek.io.testing.extend_cube.test_fails_overlapping_payload_enrich(driver, function_store, existing_cube)[source]

Forbidden by spec, results in problems during query.

kartothek.io.testing.extend_cube.test_fails_overlapping_payload_overwrite(driver, function_store, existing_cube)[source]

Forbidden by spec, results in problems during query.

kartothek.io.testing.extend_cube.test_fails_overlapping_payload_partial(driver, function_store, existing_cube)[source]

Forbidden by spec, results in problems during query.

kartothek.io.testing.extend_cube.test_fails_overlapping_payload_seed(driver, function_store, existing_cube)[source]

Forbidden by spec, results in problems during query.

kartothek.io.testing.extend_cube.test_fails_seed_dataset(driver, function_store, existing_cube)[source]

Users cannot overwrite seed dataset since it is used for consisteny checks.

kartothek.io.testing.extend_cube.test_overwrite_move_columns(driver, function_store, existing_cube)[source]

Move columns v1 and i1 from enrich to extra.

kartothek.io.testing.extend_cube.test_overwrite_single(driver, function_store, existing_cube)[source]

Simple overwrite of the enrich dataset.

kartothek.io.testing.extend_cube.test_rowgroups_are_applied_when_df_serializer_is_passed_to_extend_cube(driver, function_store, existing_cube, chunk_size)[source]

Test that the dataset is split into row groups depending on the chunk size

kartothek.io.testing.extend_cube.test_simple(driver, function_store, existing_cube)[source]

Simple integration test w/ single extra dataset.

kartothek.io.testing.extend_cube.test_single_rowgroup_when_df_serializer_is_not_passed_to_extend_cube(driver, function_store, existing_cube)[source]

Test that the dataset has a single row group as default path