Skip to content

Commit a277c1a

Browse files
fix: Removed internal system columns and fixed quoting
1 parent c7eed01 commit a277c1a

1 file changed

Lines changed: 10 additions & 2 deletions

File tree

sqlmesh/core/engine_adapter/risingwave.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,11 +44,19 @@ def columns(
4444
.from_("rw_catalog.rw_columns")
4545
.join("rw_catalog.rw_relations", on="rw_relations.id=rw_columns.relation_id")
4646
.join("rw_catalog.rw_schemas", on="rw_schemas.id=rw_relations.schema_id")
47-
.where(exp.column("name",db="rw_relations",quoted=False).eq(table.alias_or_name))
47+
.where(
48+
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"),
52+
)
53+
)
4854
)
4955

5056
if table.args.get("db"):
51-
sql = sql.where(exp.column("name",db="rw_schemas",quoted=False).eq(table.args["db"].name))
57+
sql = sql.where(
58+
exp.column("name", db="rw_schemas", quoted=False).eq(table.args["db"].name)
59+
)
5260

5361
self.execute(sql)
5462
resp = self.cursor.fetchall()

0 commit comments

Comments
 (0)