Log leaked trapped exits

dashbitco · May 3, 2023 · 5fae38e · 5fae38e
1 parent f9bbe26
commit 5fae38e
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/lib/broadway/topology/batch_processor_stage.ex b/lib/broadway/topology/batch_processor_stage.ex
@@ -33,6 +33,15 @@ defmodule Broadway.Topology.BatchProcessorStage do
   end
 
   @impl true
+  def handle_info({:EXIT, pid, reason}, state) when reason not in [:normal, :shutdown] do
+    Logger.error(
+      "Batch processor received a trapped exit from #{inspect(pid)} with reason: " <>
+        Exception.format_exit(reason)
+    )
+
+    {:noreply, [], state}
+  end
+
   def handle_info(_msg, state) do
     {:noreply, [], state}
   end

diff --git a/lib/broadway/topology/processor_stage.ex b/lib/broadway/topology/processor_stage.ex
@@ -43,6 +43,15 @@ defmodule Broadway.Topology.ProcessorStage do
   end
 
   @impl true
+  def handle_info({:EXIT, pid, reason}, state) when reason not in [:normal, :shutdown] do
+    Logger.error(
+      "Processor received a trapped exit from #{inspect(pid)} with reason: " <>
+        Exception.format_exit(reason)
+    )
+
+    {:noreply, [], state}
+  end
+
   def handle_info(_msg, state) do
     {:noreply, [], state}
   end