Metrics fixes for metrics_v0 (#2188)

opensource-observer · Sep 23, 2024 · 2d3523b · 2d3523b
1 parent c68fc1a
commit 2d3523b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/warehouse/metrics_mesh/config.py b/warehouse/metrics_mesh/config.py
@@ -45,10 +45,10 @@ def pool_manager_factory(config: ClickhouseConnectionConfig):
                     os.environ.get("SQLMESH_CLICKHOUSE_CONCURRENT_TASKS", "16")
                 ),
                 send_receive_timeout=1800,
-                connection_settings={"allow_nondeterministic_mutations": 1},
+                # connection_settings={"allow_nondeterministic_mutations": 1},
                 connection_pool_options={
                     "maxsize": 24,
-                    "retries": 3,
+                    "retries": 0,
                 },
             ),
             state_connection=GCPPostgresConnectionConfig(

diff --git a/warehouse/metrics_tools/lib/factories/definition.py b/warehouse/metrics_tools/lib/factories/definition.py
@@ -729,7 +729,7 @@ class DailyTimeseriesRollingWindowOptions(t.TypedDict):
 def join_all_of_entity_type(evaluator: MacroEvaluator, *, db: str, tables: t.List[str], columns: t.List[str]):
     query = exp.select(*columns).from_(sqlglot.to_table(f"{db}.{tables[0]}"))
     for table in tables[1:]:
-        query.union(exp.select(*columns).from_(sqlglot.to_table(f"{db}.{table}")), distinct=False)
+        query = query.union(exp.select(*columns).from_(sqlglot.to_table(f"{db}.{table}")), distinct=False)
     return query