diff --git a/dbt/adapters/duckdb/plugins/sqlalchemy.py b/dbt/adapters/duckdb/plugins/sqlalchemy.py index 3adadf57..b66c8de8 100644 --- a/dbt/adapters/duckdb/plugins/sqlalchemy.py +++ b/dbt/adapters/duckdb/plugins/sqlalchemy.py @@ -13,7 +13,7 @@ class Plugin(BasePlugin): def initialize(self, plugin_config: Dict[str, Any]): - self.engine = create_engine(plugin_config["connection_url"]) + self.engine = create_engine(plugin_config.pop("connection_url"), **plugin_config) def load(self, source_config: SourceConfig) -> pd.DataFrame: if "query" in source_config: