Skip to content

Commit 95c66a2

Browse files
committed
Finish one-shot writable scans in the first producer turn
1 parent dd37d26 commit 95c66a2

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

‎vgi/_test_fixtures/simple_writable.py‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -337,6 +337,7 @@ def process(cls, params: ProcessParams[None], state: _ScanState, out: OutputColl
337337
state.cursor = len(state.rows)
338338
arrow_arrays = [pa.array(col, type=state.schema.field(i).type) for i, col in enumerate(col_arrays)]
339339
out.emit(pa.RecordBatch.from_arrays(arrow_arrays, schema=state.schema))
340+
out.finish()
340341

341342

342343
@dataclass(kw_only=True)

0 commit comments

Comments
 (0)