Skip to content

Commit e773c49

Browse files
[async] Fix _cursor after #2365
1 parent 58c8644 commit e773c49

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/snowflake/connector/aio/_result_set.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,12 @@ def __init__(
174174
result_chunks: list[JSONResultBatch] | list[ArrowResultBatch],
175175
prefetch_thread_num: int,
176176
) -> None:
177-
super().__init__(cursor, result_chunks, prefetch_thread_num)
177+
super().__init__(
178+
cursor,
179+
result_chunks,
180+
prefetch_thread_num,
181+
use_mp=False, # async code depends on aio rather than multiprocessing
182+
)
178183
self.batches = cast(
179184
Union[list[JSONResultBatch], list[ArrowResultBatch]], self.batches
180185
)

0 commit comments

Comments
 (0)