execute local subscription dispatch synchronously

Frameio · Jun 11, 2024 · c8d845b · c8d845b
1 parent 253b1f3
commit c8d845b
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/lib/absinthe/subscription/proxy.ex b/lib/absinthe/subscription/proxy.ex
@@ -44,11 +44,7 @@ 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, [
-        state.pubsub,
-        payload.mutation_result,
-        payload.subscribed_fields
-      ])
+      Subscription.Local.publish_mutation(state.pubsub, payload.mutation_result, payload.subscribed_fields)
     end
 
     {:noreply, state}