fix: local broadcast transaction broadcaster (#2153)

* fix: just do a local_broadcast here * fix: not used * fix: bump version
Logflare · Jul 19, 2024 · a76552e · a76552e
1 parent 86bc382
commit a76552e
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-1.7.12
+1.7.13
diff --git a/lib/logflare/context_cache/supervisor.ex b/lib/logflare/context_cache/supervisor.ex
@@ -65,7 +65,6 @@ defmodule Logflare.ContextCache.Supervisor do
   """
   def maybe_start_cainophile do
     spec = cainophile_child_spec()
-    Supervisor.which_children(__MODULE__)
     Supervisor.start_child(__MODULE__, spec)
   end
 

diff --git a/lib/logflare/context_cache/transaction_broadcaster.ex b/lib/logflare/context_cache/transaction_broadcaster.ex
@@ -47,7 +47,7 @@ defmodule Logflare.ContextCache.TransactionBroadcaster do
   def handle_info(%Transaction{changes: _changes} = transaction, state) do
     Logger.debug("WAL record received from cainophile: #{inspect(transaction)}")
     # broadcast it
-    Phoenix.PubSub.broadcast(Logflare.PubSub, "wal_transactions", transaction)
+    Phoenix.PubSub.local_broadcast(Logflare.PubSub, "wal_transactions", transaction)
     {:noreply, state}
   end