We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1410505 commit 1f6ba4dCopy full SHA for 1f6ba4d
1 file changed
python/functionstream-runtime/src/fs_runtime/runner.py
@@ -21,21 +21,7 @@
21
logger = logging.getLogger(__name__)
22
23
from .store.fs_context import WitContext, convert_config_to_dict
24
-from fs_api_advanced import (
25
- Codec,
26
- ValueState,
27
- MapState,
28
- ListState,
29
- PriorityQueueState,
30
- AggregatingState,
31
- ReducingState,
32
- KeyedListStateFactory,
33
- KeyedValueStateFactory,
34
- KeyedMapStateFactory,
35
- KeyedPriorityQueueStateFactory,
36
- KeyedAggregatingStateFactory,
37
- KeyedReducingStateFactory,
38
-)
+import fs_api_advanced
39
40
41
_DRIVER: Optional[FSProcessorDriver] = None
0 commit comments