Skip to content

Commit 9c0c933

Browse files
abc3acco
authored andcommitted
fix: put back execution redis command in fun
1 parent 7d490fe commit 9c0c933

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/sequin/sinks/redis/client.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ defmodule Sequin.Sinks.Redis.Client do
2121
with {:ok, connection} <- ConnectionCache.connection(sink) do
2222
commands = xadd_commands(consumer, messages)
2323

24-
{time, res} = :timer.tc(__MODULE__, :qp, [connection, commands], :millisecond)
24+
{time, res} = :timer.tc(fn -> qp(connection, commands) end, :millisecond)
2525

2626
if time > 200 do
2727
Logger.warning("[Sequin.Sinks.Redis] Slow command execution", duration_ms: time)

0 commit comments

Comments
 (0)