Fix unbounded concurrency

absinthe-graphql · Jul 23, 2024 · 486ba3e · 486ba3e
1 parent 84d6efa
commit 486ba3e
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}