     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

      SELECT height
      FROM #{table}
    )
    LIMIT 1000
    ;
    """)
    {:ok, %{rows: rows}} = SQL.query(Repo, q)
