Skip to content

Commit 3bc661b

Browse files
committed
Fix rebase conflicts
1 parent 6b621a6 commit 3bc661b

2 files changed

Lines changed: 7 additions & 3 deletions

File tree

kartothek/io_components/merge.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import logging
22
from functools import partial, reduce
3-
from typing import Dict, List, Optional
3+
from typing import TYPE_CHECKING, Callable, Dict, List, Optional, cast
44

55
import pandas as pd
66

@@ -10,6 +10,10 @@
1010
from kartothek.io_components.read import dispatch_metapartitions_from_factory
1111
from kartothek.io_components.utils import _instantiate_store, _make_callable
1212

13+
if TYPE_CHECKING:
14+
from simplekv import KeyValueStore
15+
16+
1317
LOGGER = logging.getLogger(__name__)
1418

1519

@@ -138,7 +142,7 @@ def align_datasets_many(
138142
dataset_factories = [
139143
DatasetFactory(
140144
dataset_uuid=dataset_uuid,
141-
store_factory=_make_callable(store),
145+
store_factory=cast(Callable[[], "KeyValueStore"], _make_callable(store)),
142146
load_schema=True,
143147
load_all_indices=False,
144148
load_dataset_metadata=True,

kartothek/io_components/read.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import warnings
2-
from typing import Callable, Iterator, List, Set, Union, cast
2+
from typing import Any, Callable, Iterator, List, Optional, Set, Union, cast, overload
33

44
import pandas as pd
55
from simplekv import KeyValueStore

0 commit comments

Comments
 (0)