Skip to main content

dispatch_step_instance

Function dispatch_step_instance 

Source
pub async fn dispatch_step_instance(
    run_id: RunId,
    step_instance_id: StepInstanceId,
    step_name: &str,
    step_type: &str,
    resolved_spec: &Value,
    resolved_params: &Value,
    nats_client: Client,
    pool: PgPool,
    tls_reloader: Arc<TlsReloader>,
) -> Result<()>
Expand description

Dispatches a step instance, handling intrinsic types or forwarding to runners via NATS.