Skip to content

Commit 6c05d70

Browse files
committed
fix test
1 parent 4efc515 commit 6c05d70

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/snowflake/snowpark/dataframe_reader.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1848,6 +1848,7 @@ def create_sqlite_connection(timeout=5.0, isolation_level=None, **kwargs):
18481848
logger.debug(f"ingestion start at: {start_time}")
18491849
if session_init_statement and isinstance(session_init_statement, str):
18501850
session_init_statement = [session_init_statement]
1851+
ds_par_params["session_init_statement"] = session_init_statement
18511852
partitioner = DataSourcePartitioner.from_dict(ds_par_params)
18521853

18531854
struct_schema = partitioner.schema

0 commit comments

Comments
 (0)