     config = config
       |> Map.put_new(:starting_block, head_block)
       |> Map.put_new(:current_block, head_block)
-    Process.send_after(self(), :next_blocks, 60_000)
+    Process.send_after(self(), :next_blocks, @tick_duration)
     {:producer, config, dispatcher: GenStage.BroadcastDispatcher, buffer_size: 100_000}
   end
 

    delta = current_height - blocks
    if delta < 1, do: 1, else: delta
  end
  
  def handle_info(msg, state) do
    Logger.info("unexpected msg: #{inspect msg}")
  end

    blocks = for {_, {:ok, block}} <- Task.yield_many(tasks, 300_000) do
      %{data: block, metadata: %{source: :resync, type: :block}}
    end
    Process.send_after(self(), :next_blocks, @tick_duration)
    Logger.info("Broadcasting missing #{length blocks} block events for #{Atom.to_string(state.token)}")
    {:noreply, blocks, state}
  end
