diff --git a/biasanalyzer/database.py b/biasanalyzer/database.py index cb449ab..7a9bfc1 100644 --- a/biasanalyzer/database.py +++ b/biasanalyzer/database.py @@ -56,6 +56,11 @@ def _initialize(self, db_url, omop_db_url=None): ATTACH '{self.omop_cdm_db_url}' as {self.omop_alias} (TYPE postgres) """) elif omop_db_url.endswith(".duckdb"): + try: + self.conn.execute(f"DETACH DATABASE {self.omop_alias}") + except (duckdb.BinderException, duckdb.CatalogException): + # ignore if not attached yet + pass self.conn.execute(f""" ATTACH '{self.omop_cdm_db_url}' as {self.omop_alias} """)