We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3fee692 commit cbee6f9Copy full SHA for cbee6f9
1 file changed
sqlmesh/core/model.py
@@ -375,10 +375,8 @@ def expression(self) -> exp.Column | exp.Tuple:
375
column = exp.to_column(self.column)
376
if not self.format:
377
return column
378
- t = exp.Tuple(expressions=[column])
379
- if self.format:
380
- t.append("expressions", exp.Literal.string(self.format))
381
- return t
+
+ return exp.Tuple(expressions=[column, exp.Literal.string(self.format)])
382
383
384
class ModelMeta(PydanticModel):
@@ -1013,7 +1011,6 @@ def exec_python(
1013
1011
assert self.time_column
1014
1012
1015
if pyspark and isinstance(df, pyspark.sql.DataFrame):
1016
- self.convert_to_time_column(end)
1017
df = df.where(
1018
f"""
1019
{self.time_column.column} BETWEEN
0 commit comments