fix dialect name

censoredplanet · Jul 13, 2023 · 4c74604 · 4c74604
1 parent 812fea4
commit 4c74604
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/pipeline/beam_tables.py b/pipeline/beam_tables.py
@@ -590,10 +590,7 @@ def derive_dashboard_rows(self, rows: beam.PCollection[schema.HyperquackRow]) ->
     pprint(dir(coder_rows))
     pprint(coder_rows.element_type)
 
-    dash_rows = (coder_rows | 'derive dashboard rows' >> SqlTransform(
-      sql_query, 
-      dialect='org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLQueryPlanner') )
-                 #.with_output_types(BigqueryOutputRow))
+    dash_rows = (coder_rows | 'derive dashboard rows' >> SqlTransform(sql_query, dialect='zetasql'))
 
     pprint("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!")
     pprint(dash_rows)