async fn block_latency_worker(
block_header_update_rx: Broadcaster<MessageBlockHeader>,
influx_channel_tx: Broadcaster<WriteQuery>,
) -> WorkerResult
async fn block_latency_worker(
block_header_update_rx: Broadcaster<MessageBlockHeader>,
influx_channel_tx: Broadcaster<WriteQuery>,
) -> WorkerResult