-record(runtime, {
    pipeline_runtime :: lightspeed@pipeline:runtime(),
    connector_plan :: lightspeed@pipeline@connector:connector_plan(),
    queue_runtime :: lightspeed@async@backpressure:runtime(),
    operator_runtime :: lightspeed@pipeline@operator:runtime(),
    batches_rev :: list(lightspeed@pipeline@orchestrator:batch()),
    retries_rev :: list(lightspeed@pipeline@orchestrator:retry_record()),
    dead_letters_rev :: list(lightspeed@pipeline@orchestrator:dead_letter_record())
}).