From be380930ec6a87a4b720bab973663c088388262c Mon Sep 17 00:00:00 2001 From: Karl Nilsson Date: Tue, 21 Sep 2021 13:09:46 +0100 Subject: [PATCH] Stream coordinator: monitor task processes So that they are cleaned up from the stream coordinator aux state when they finish instead of growing indefinitely. --- deps/rabbit/src/rabbit_stream_coordinator.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl index 70989e383b..f32d6de61d 100644 --- a/deps/rabbit/src/rabbit_stream_coordinator.erl +++ b/deps/rabbit/src/rabbit_stream_coordinator.erl @@ -634,7 +634,7 @@ run_action(Action, StreamId, #{node := _Node, ActionFun(), unlink(Coordinator) end), - Effects = [], + Effects = [{monitor, process, aux, Pid}], Actions = Actions0#{Pid => {StreamId, Action, Args}}, {no_reply, Aux#aux{actions = Actions}, Log, Effects}.