Skip to content

Commit 4893131

Browse files
[Async] Apply #2247 to async code
1 parent 6ec0460 commit 4893131

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/snowflake/connector/aio/_cursor.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1115,6 +1115,7 @@ async def _upload(
11151115
self,
11161116
"", # empty command because it is triggered by directly calling this util not by a SQL query
11171117
ret,
1118+
force_put_overwrite=False, # _upload should respect user decision on overwriting
11181119
)
11191120
await file_transfer_agent.execute()
11201121
await self._init_result_and_meta(file_transfer_agent.result())
@@ -1184,6 +1185,7 @@ async def _upload_stream(
11841185
"", # empty command because it is triggered by directly calling this util not by a SQL query
11851186
ret,
11861187
source_from_stream=input_stream,
1188+
force_put_overwrite=False, # _upload should respect user decision on overwriting
11871189
)
11881190
await file_transfer_agent.execute()
11891191
await self._init_result_and_meta(file_transfer_agent.result())

0 commit comments

Comments
 (0)