We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8c11e97 commit c7eed01Copy full SHA for c7eed01
1 file changed
sqlmesh/core/engine_adapter/risingwave.py
@@ -44,11 +44,11 @@ def columns(
44
.from_("rw_catalog.rw_columns")
45
.join("rw_catalog.rw_relations", on="rw_relations.id=rw_columns.relation_id")
46
.join("rw_catalog.rw_schemas", on="rw_schemas.id=rw_relations.schema_id")
47
- .where(exp.column("rw_relations.name", quoted=False).eq(table.alias_or_name))
+ .where(exp.column("name",db="rw_relations",quoted=False).eq(table.alias_or_name))
48
)
49
50
if table.args.get("db"):
51
- sql = sql.where(exp.column("rw_schemas.name").eq(table.args["db"].name))
+ sql = sql.where(exp.column("name",db="rw_schemas",quoted=False).eq(table.args["db"].name))
52
53
self.execute(sql)
54
resp = self.cursor.fetchall()
0 commit comments