diff --git a/test/lightning_web/channels/worker_channel_test.exs b/test/lightning_web/channels/worker_channel_test.exs index ff4435dd6d..3e790ad424 100644 --- a/test/lightning_web/channels/worker_channel_test.exs +++ b/test/lightning_web/channels/worker_channel_test.exs @@ -65,9 +65,12 @@ defmodule LightningWeb.WorkerChannelTest do ref = push(socket, "claim", %{"demand" => 1}) - assert_reply ref, :ok, %{ - runs: [%{"id" => ^run_id, "token" => token}] - } + assert_reply ref, + :ok, + %{ + runs: [%{"id" => ^run_id, "token" => token}] + }, + 1_000 Lightning.Stub.freeze_time(DateTime.utc_now() |> DateTime.add(5, :second))