Skip to content

Commit 9c4a9ca

Browse files
Fix: Updated arguments for column objects to use table over db
1 parent a277c1a commit 9c4a9ca

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

sqlmesh/core/engine_adapter/risingwave.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -46,16 +46,16 @@ def columns(
4646
.join("rw_catalog.rw_schemas", on="rw_schemas.id=rw_relations.schema_id")
4747
.where(
4848
exp.and_(
49-
exp.column("name", db="rw_relations").eq(table.alias_or_name),
50-
exp.column("name", db="rw_columns").neq("_row_id"),
51-
exp.column("name", db="rw_columns").neq("_rw_timestamp"),
49+
exp.column("name", table="rw_relations").eq(table.alias_or_name),
50+
exp.column("name", table="rw_columns").neq("_row_id"),
51+
exp.column("name", table="rw_columns").neq("_rw_timestamp"),
5252
)
5353
)
5454
)
5555

5656
if table.args.get("db"):
5757
sql = sql.where(
58-
exp.column("name", db="rw_schemas", quoted=False).eq(table.args["db"].name)
58+
exp.column("name", table="rw_schemas", quoted=False).eq(table.args["db"].name)
5959
)
6060

6161
self.execute(sql)

0 commit comments

Comments
 (0)