fix: 🐛 cluster detection

not using table because table on first migration never exists!
coingaming · Jan 8, 2025 · 6f30a4f · 6f30a4f
1 parent 5e6ccde
commit 6f30a4f
Showing 1 changed file with 4 additions and 8 deletions.
diff --git a/lib/plausible/migration_utils.ex b/lib/plausible/migration_utils.ex
@@ -3,14 +3,10 @@ defmodule Plausible.MigrationUtils do
   Base module for to use in Clickhouse migrations
   """
 
-  def on_cluster_statement(table) do
-    if(clustered_table?(table), do: "ON CLUSTER '#{cluster_name()}'", else: "")
-  end
-
-  def clustered_table?(table) do
-    case Plausible.IngestRepo.query("SELECT 1 FROM system.replicas WHERE table = '#{table}'") do
-      {:ok, %{rows: []}} -> false
-      {:ok, _} -> true
+  def on_cluster_statement(_table) do
+    case cluster_name() do
+      {:ok, cluster} -> "ON CLUSTER '#{cluster}'"
+      _ -> ""
     end
   end