diff --git a/lib/absinthe/subscription/proxy.ex b/lib/absinthe/subscription/proxy.ex index 4c16cb77..8e5650df 100644 --- 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}