Scoria.Workflows (scoria v0.1.0)

Copy Markdown View Source

Durable workflow persistence and lifecycle transitions.

Summary

Functions

append_checkpoint(run_id, step_id, attrs)
append_event(run_id, step_id, attrs)
approve(approval_or_id, status, attrs \\ %{})
claim_step(step_id)
complete_step(step_or_id, result_envelope, opts \\ [])
create_handoff(step, attrs)
create_run(attrs \\ %{})
create_step(run_id, attrs)
fail_step(step_or_id, error_envelope, opts \\ [])
get_approval!(id)
get_approval_lineage!(approval_id)
get_remote_approval_lineage!(approval_id)
get_run!(id)
get_run_tree!(id)
get_step!(id)
list_pending_approvals(filters \\ %{})
list_pending_remote_approvals(filters \\ %{})
list_run_checkpoints(run_id)
list_run_events(run_id)
list_run_steps(run_id)
list_runnable_steps()
mark_waiting_for_approval(run_id, step_id, attrs)
next_step_sequence(run_id)
record_connector_auth_failure(run_id, step_id, payload)
record_connector_scope_escalation(run_id, step_id, payload)
request_baseline_promotion(attrs)
request_remote_approval(run_id, step_id, attrs)
resume_run(run_id)
retry_step(step_id)
subscribe_run(run_id)

Functions

append_checkpoint(run_id, step_id, attrs)

append_event(run_id, step_id, attrs)

approve(approval_or_id, status, attrs \\ %{})

claim_step(step_id)

complete_step(step_or_id, result_envelope, opts \\ [])

create_handoff(step, attrs)

create_run(attrs \\ %{})

create_step(run_id, attrs)

fail_step(step_or_id, error_envelope, opts \\ [])

get_approval!(id)

get_approval_lineage!(approval_id)

get_remote_approval_lineage!(approval_id)

get_run!(id)

get_run_tree!(id)

get_step!(id)

list_pending_approvals(filters \\ %{})

list_pending_remote_approvals(filters \\ %{})

list_run_checkpoints(run_id)

list_run_events(run_id)

list_run_steps(run_id)

list_runnable_steps()

mark_waiting_for_approval(run_id, step_id, attrs)

next_step_sequence(run_id)

record_connector_auth_failure(run_id, step_id, payload)

record_connector_scope_escalation(run_id, step_id, payload)

request_baseline_promotion(attrs)

request_remote_approval(run_id, step_id, attrs)

resume_run(run_id)

retry_step(step_id)

subscribe_run(run_id)