Conduit.WorkflowRunner

Functions

fnenqueueenqueue(storage : s, workflow_id : String, config : Conduit.WorkflowConfig) : Result(String, String)#

Enqueue a workflow_runner job for the given workflow_id. Called immediately after inserting a new workflow row.

fnexecuteexecute(storage : s, payload : String)#

Execute a workflow by id. This is called by the registered performer.

Delegates to prun after loading and validating the workflow row.

fnjob_typejob_type() : String#

The job_type constant (public so callers can use it in tests).