Skip to content

Commit 7c590c2

Browse files
authored
Minor improvement: also allow collect() taking constant. (#216)
1 parent 408af77 commit 7c590c2

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

python/cocoindex/flow.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -254,7 +254,7 @@ def __init__(self, flow_builder_state: _FlowBuilderState,
254254
self._flow_builder_state = flow_builder_state
255255
self._engine_data_collector = data_collector
256256

257-
def collect(self, **kwargs: DataSlice | GeneratedField):
257+
def collect(self, **kwargs):
258258
"""
259259
Collect data into the collector.
260260
"""
@@ -269,7 +269,8 @@ def collect(self, **kwargs: DataSlice | GeneratedField):
269269
else:
270270
raise ValueError(f"Unexpected generated field: {v}")
271271
else:
272-
regular_kwargs.append((k, _data_slice_state(v).engine_data_slice))
272+
regular_kwargs.append(
273+
(k, self._flow_builder_state.get_data_slice(v)))
273274

274275
self._flow_builder_state.engine_flow_builder.collect(
275276
self._engine_data_collector, regular_kwargs, auto_uuid_field)

0 commit comments

Comments
 (0)