We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a53e770 commit 1622038Copy full SHA for 1622038
piperider_cli/datasource/duckdb.py
@@ -104,6 +104,15 @@ def to_database_url(self, database):
104
raise PipeRiderDataBaseConnectionError(self.name, self.type_name, db_path=duckdb_path)
105
return f"duckdb:///{duckdb_path}"
106
107
+ def engine_args(self):
108
+
109
+ args = dict(
110
+ preload_extensions=list(self.credential.get('extensions', [])),
111
+ config=dict(self.credential.get('settings', {}))
112
+ )
113
114
+ return dict(connect_args=args)
115
116
def _formalize_table_name(self, name):
117
if not name:
118
return f'{self.type_name}_table'
0 commit comments