Fix(motherduck): filter on catalog name in DuckDB _get_data_objects q…

…uery (TobikoData#2699)
etonlels · May 29, 2024 · 71fdbe4 · 71fdbe4
1 parent aa3ee94
commit 71fdbe4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/sqlmesh/core/engine_adapter/duckdb.py b/sqlmesh/core/engine_adapter/duckdb.py
@@ -94,7 +94,9 @@ def _get_data_objects(
                 .as_("type"),
             )
             .from_(exp.to_table("information_schema.tables"))
-            .where(exp.column("table_schema").eq(schema_name))
+            .where(
+                exp.column("table_catalog").eq(catalog), exp.column("table_schema").eq(schema_name)
+            )
         )
         if object_names:
             query = query.where(exp.column("table_name").isin(*object_names))