We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dc6c558 commit cd78b7fCopy full SHA for cd78b7f
snowflake_utils/models/table.py
@@ -200,8 +200,6 @@ def copy_into(
200
stage: str | None = None,
201
files: list[str] | None = None,
202
) -> None:
203
- if stage:
204
- path = f"@{stage}/{path}"
205
col_str = f"({', '.join(target_columns)})" if target_columns else ""
206
files_clause = ""
207
if files:
@@ -226,6 +224,7 @@ def copy_into(
226
224
storage_integration,
227
225
full_refresh,
228
sync_tags,
+ stage,
229
)
230
with connect() as connection:
231
cursor = connection.cursor()
@@ -244,6 +243,7 @@ def copy_into(
244
243
245
246
247
248
249
def create_table(self, full_refresh: bool, execute_statement: callable) -> None:
0 commit comments