From 486ba3e33e954bf2749fbc0e704b1407d09afc4f Mon Sep 17 00:00:00 2001 From: Bryan Joseph Date: Tue, 23 Jul 2024 11:16:10 -0500 Subject: [PATCH] Fix unbounded concurrency --- 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 4c16cb77b3..fa70b86831 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}