Skip to content

Commit 49783c2

Browse files
committed
fix: stage path
1 parent bb88b27 commit 49783c2

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

snowflake_utils/models/table.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -511,11 +511,17 @@ def copy_custom(
511511
query = f"""
512512
COPY INTO {self.fqn} ({column_names})
513513
FROM
514-
(select {definitions} from @{self.stage}/)
514+
(select {definitions} from @{stage}/{path})
515515
FILE_FORMAT = ( FORMAT_NAME ='{{file_format}}')
516516
"""
517517
return self._copy(
518-
query, path, file_format, storage_integration, full_refresh, sync_tags
518+
query,
519+
path,
520+
file_format,
521+
storage_integration,
522+
full_refresh,
523+
sync_tags,
524+
stage,
519525
)
520526

521527
def merge_custom(

0 commit comments

Comments
 (0)