Skip to content

Commit 6a0f625

Browse files
committed
Port fix for InvalidConsensus to Uncataloged
They have a similar style where Uncataloged could also receive :queue_unavailable.
1 parent c978b61 commit 6a0f625

File tree

1 file changed

+4
-1
lines changed
  • apps/indexer/lib/indexer/token_transfer/uncataloged

1 file changed

+4
-1
lines changed

apps/indexer/lib/indexer/token_transfer/uncataloged/worker.ex

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,10 @@ defmodule Indexer.TokenTransfer.Uncataloged.Worker do
7676
end
7777

7878
def handle_info({ref, {:error, reason}}, %{task_ref: ref, retry_interval: millis} = state) do
79-
Logger.error(fn -> inspect(reason) end)
79+
case reason do
80+
:queue_unavailable -> :ok
81+
_ -> Logger.error(fn -> inspect(reason) end)
82+
end
8083

8184
Process.demonitor(ref, [:flush])
8285
Process.send_after(self(), :push_front_blocks, millis)

0 commit comments

Comments
 (0)