Skip to content

Commit 45db9de

Browse files
kjnilssonmergify-bot
authored andcommitted
Stream coordinator: monitor task processes
So that they are cleaned up from the stream coordinator aux state when they finish instead of growing indefinitely. (cherry picked from commit be38093)
1 parent cc14442 commit 45db9de

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbit/src/rabbit_stream_coordinator.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -634,7 +634,7 @@ run_action(Action, StreamId, #{node := _Node,
634634
ActionFun(),
635635
unlink(Coordinator)
636636
end),
637-
Effects = [],
637+
Effects = [{monitor, process, aux, Pid}],
638638
Actions = Actions0#{Pid => {StreamId, Action, Args}},
639639
{no_reply, Aux#aux{actions = Actions}, Log, Effects}.
640640

0 commit comments

Comments
 (0)