From 536e6d8917c9973df54eca5bebc21628e09730a2 Mon Sep 17 00:00:00 2001 From: Andrew <15331990+ahuang11@users.noreply.github.com> Date: Mon, 17 Jun 2024 08:04:50 -0700 Subject: [PATCH] Fix multiple SQL transforms if `;` in override query (#578) --- lumen/sources/duckdb.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lumen/sources/duckdb.py b/lumen/sources/duckdb.py index d2f80ef4b..69151411b 100644 --- a/lumen/sources/duckdb.py +++ b/lumen/sources/duckdb.py @@ -81,7 +81,7 @@ def get(self, table, **query): if self.filter_in_sql: sql_transforms = [SQLFilter(conditions=conditions)] + sql_transforms for st in sql_transforms: - sql_expr = st.apply(sql_expr) + sql_expr = st.apply(sql_expr.rstrip(";")) df = self._connection.execute(sql_expr).fetch_df(date_as_object=True) if not self.filter_in_sql: df = Filter.apply_to(df, conditions=conditions)