ObanPowertools.Workflow.Runtime (oban_powertools v0.5.0)

Copy Markdown View Source

Durable workflow runtime transitions, cancellation, awaits, signals, recovery, and callbacks.

Semantics version 2 is the v1.2 lifecycle contract. New rows default to that contract, while pre-v1.2 rows remain on an explicit compatibility path until a v2 runtime transition writes the newer durable cause fields. Historical rows are never silently reinterpreted as if they were created under the v1.2 contract.

Summary

Functions

await_step(repo, workflow_id, step_name, attrs \\ %{})
compatibility_policy()
complete_step(repo, workflow_id, step_name, attrs \\ %{})
deliver_signal(repo, attrs)
dispatch_callbacks(repo, opts \\ [])
lifecycle_contract()
reconcile_workflow(repo, workflow_id, now \\ DateTime.utc_now())
recover_step(repo, workflow_id, step_name, action, attrs \\ %{})
recover_step_by_id(repo, step_id, action, attrs \\ %{})
request_cancel(repo, workflow_id, attrs \\ %{})
semantics_profile(workflow)
semantics_version()
step_diagnosis(step)
step_executable_actions(step)
workflow_diagnosis(workflow, steps)
workflow_executable_actions(workflow, steps)

Functions

await_step(repo, workflow_id, step_name, attrs \\ %{})

compatibility_policy()

complete_step(repo, workflow_id, step_name, attrs \\ %{})

deliver_signal(repo, attrs)

dispatch_callbacks(repo, opts \\ [])

lifecycle_contract()

reconcile_workflow(repo, workflow_id, now \\ DateTime.utc_now())

recover_step(repo, workflow_id, step_name, action, attrs \\ %{})

recover_step_by_id(repo, step_id, action, attrs \\ %{})

request_cancel(repo, workflow_id, attrs \\ %{})

semantics_profile(workflow)

semantics_version()

step_diagnosis(step)

step_executable_actions(step)

workflow_diagnosis(workflow, steps)

workflow_executable_actions(workflow, steps)