Skip to content

Commit d32d30d

Browse files
committed
Catch exits if already down when trapping exits
1 parent f52f2f7 commit d32d30d

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

lib/broadway/topology/terminator.ex

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,9 @@ defmodule Broadway.Topology.Terminator do
1010
@spec trap_exit(GenServer.server()) :: :ok
1111
def trap_exit(terminator) do
1212
GenServer.call(terminator, :trap_exit)
13+
catch
14+
# If it is already down, we ignore it
15+
:exit, _ -> :ok
1316
end
1417

1518
@impl true

0 commit comments

Comments
 (0)