From c8d845bc19fbed7d3445187bc0aff8d49345b9e4 Mon Sep 17 00:00:00 2001 From: Michael Shapiro Date: Tue, 11 Jun 2024 16:28:38 -0700 Subject: [PATCH] execute local subscription dispatch synchronously --- lib/absinthe/subscription/proxy.ex | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) 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}