From a8de84c39048ad0a9c6e6ac539b252f85c2d9a3c Mon Sep 17 00:00:00 2001
From: Michael Shapiro <mshapiro@frame.io>
Date: Tue, 11 Jun 2024 16:28:38 -0700
Subject: [PATCH] execute local subscription dispatch synchronously

---
 lib/absinthe/subscription/proxy.ex | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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