Function run_idempotent 

pub async fn run_idempotent(
    ctx: Arc<LoadContext>,
    path: LoadPath,
    latencies: Latencies,
) -> ProducerOutput

The idempotent or compacted producer of path, until the load stops.

A send that fails is sent again, up to max_send_attempts in all, and is recorded as failed and as retried. A compacted send whose key has a later value in flight is not sent again: see superseded.

latencies is where its send latencies go.