feat: debug log with the count of received events

mbta · Oct 20, 2023 · 65cf6c1 · 65cf6c1
1 parent 7fb8734
commit 65cf6c1
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/concentrate/merge_filter.ex b/lib/concentrate/merge_filter.ex
@@ -64,6 +64,11 @@ defmodule Concentrate.MergeFilter do
 
   @impl GenStage
   def handle_events(events, from, state) do
+    _ =
+      Logger.debug(fn ->
+        "#{__MODULE__} received events from=#{inspect(from)} event_count=#{length(events)}"
+      end)
+
     {state, updated_keys} =
       Enum.reduce(events, {state, []}, fn event, {state, updated_keys} ->
         key = FeedUpdate.url(event) || from
@@ -122,7 +127,7 @@ defmodule Concentrate.MergeFilter do
 
     _ =
       Logger.debug(fn ->
-        "#{__MODULE__} merge time=#{time / 1_000}"
+        "#{__MODULE__} merge time=#{time / 1_000} keys=#{inspect(keys, limit: :infinity)}"
       end)
 
     {time, filtered} = :timer.tc(&Filter.run/2, [merged, state.filters])