Skip to content

Commit 852112c

Browse files
committed
hotfix: set missing session_id in query exporter
1 parent 5d6df24 commit 852112c

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

core/lib/canary/interactions/query_exporter.ex

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,11 @@ defmodule Canary.Interactions.QueryExporter do
7373
{keep, send} =
7474
search
7575
|> Enum.reduce({%{}, []}, fn {session_id, items}, {keep_acc, send_acc} ->
76-
{items_to_keep, items_to_send} = dedupe(items, now, export_delay_ms)
76+
{items_to_keep, items_to_send} =
77+
items
78+
|> Enum.map(&Map.put(&1, :session_id, session_id))
79+
|> dedupe(now, export_delay_ms)
80+
7781
{Map.put(keep_acc, session_id, items_to_keep), send_acc ++ items_to_send}
7882
end)
7983

0 commit comments

Comments
 (0)