kartothek.core.utils module

kartothek.core.utils.ensure_store(store: Union[str, simplekv.KeyValueStore, Callable[], simplekv.KeyValueStore]]) → simplekv.KeyValueStore

Convert the store argument to a KeyValueStore, without pickle test.

kartothek.core.utils.lazy_store(store: Union[str, simplekv.KeyValueStore, Callable[], simplekv.KeyValueStore]]) → Callable[], simplekv.KeyValueStore]

Create a store factory from the input. Acceptable inputs are * Storefact store url * Callable[[], KeyValueStore] * KeyValueStore

If a KeyValueStore is provided, it is verified that the store is serializable (i.e. that pickle.dumps does not raise an exception).