Merge pull request #5 from Frameio/mikes/synchronous-local-dispatch

[REL-114] Execute local subscription dispatch synchronously
Frameio · Jun 13, 2024 · 518f29e · 518f29e
2 parents 253b1f3 + a8de84c
commit 518f29e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/absinthe/subscription/proxy.ex b/lib/absinthe/subscription/proxy.ex
@@ -44,11 +44,11 @@ defmodule Absinthe.Subscription.Proxy do
     # bottleneck execution inside each proxy process
 
     unless payload.node == state.pubsub.node_name() do
-      Task.Supervisor.start_child(state.task_super, Subscription.Local, :publish_mutation, [
+      Subscription.Local.publish_mutation(
         state.pubsub,
         payload.mutation_result,
         payload.subscribed_fields
-      ])
+      )
     end
 
     {:noreply, state}