fix

5 years ago · f80b2ff254
parent 48c18b135a
commit f80b2ff254
1 changed files with 1 additions and 1 deletions
--- a/apps/indexer/lib/indexer/buffered_task.ex
+++ b/apps/indexer/lib/indexer/buffered_task.ex
@ -438,7 +438,7 @@ defmodule Indexer.BufferedTask do
  end

  # get more work from `init/2`
-  defp schedule_next(%BufferedTask{poll: true} = state) do
+  defp schedule_next(%BufferedTask{poll: true, bound_queue: %BoundQueue{size: 0}} = state) do
    do_initial_stream(state)
  end