Fix(motherduck): filter on catalog name in DuckDB _get_data_objects query (#2699)

treysp · web-flow · commit 71fdbe457889 · 2024-05-29T15:46:47.000-05:00
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))

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,9 @@ def _get_data_objects(`
`94`	`94`	`.as_("type"),`
`95`	`95`	`)`
`96`	`96`	`.from_(exp.to_table("information_schema.tables"))`
`97`		`- .where(exp.column("table_schema").eq(schema_name))`
	`97`	`+ .where(`
	`98`	`+ exp.column("table_catalog").eq(catalog), exp.column("table_schema").eq(schema_name)`
	`99`	`+ )`
`98`	`100`	`)`
`99`	`101`	`if object_names:`
`100`	`102`	`query = query.where(exp.column("table_name").isin(*object_names))`