Read-side of DBOS (list/status/steps), over both a DBOS instance and a DBOSClient via a protocol. Clojure maps in, Clojure maps out.
Read-side of DBOS (list/status/steps), over both a DBOS instance and a DBOSClient via a protocol. Clojure maps in, Clojure maps out.
(->list-workflows-input m)Build a ListWorkflowsInput from a map. Supported keys:
Build a ListWorkflowsInput from a map. Supported keys: - :workflow-ids - Collection of workflow UUIDs to query - :workflow-name - Filter by workflow function name - :statuses - Collection of status strings (PENDING, ERROR, etc.) - :status - Single status string - :queue-name - Filter by queue name - :executor-ids - Collection of executor IDs - :start-time - OffsetDateTime for created_at >= filter - :end-time - OffsetDateTime for created_at <= filter - :limit - Max results to return - :offset - Pagination offset - :sort-desc? - Sort by creation time descending - :load-input? - Include workflow inputs in result - :load-output? - Include workflow outputs in result - :workflow-id-prefix - Filter by workflow-id prefix
(get-workflow-status queryable workflow-id)Get the status map of a single workflow by its ID, or nil if not found.
queryable is either a DBOS instance or a DBOSClient.
Get the status map of a single workflow by its ID, or nil if not found. `queryable` is either a DBOS instance or a DBOSClient.
(list-workflow-steps queryable workflow-id)List the recorded steps of a workflow (by id) as a vector of maps, in
execution order. queryable is either a DBOS instance or a DBOSClient.
Each step map has :function-id, :function-name, :output, :error, :child-workflow-id, :started-at, :completed-at, :started-at-epoch-ms, :completed-at-epoch-ms, and :serialization.
List the recorded steps of a workflow (by id) as a vector of maps, in execution order. `queryable` is either a DBOS instance or a DBOSClient. Each step map has :function-id, :function-name, :output, :error, :child-workflow-id, :started-at, :completed-at, :started-at-epoch-ms, :completed-at-epoch-ms, and :serialization.
(list-workflows queryable query-params)Query workflows from DBOS with optional filters, returning a vector of
status maps. queryable is either a DBOS instance or a DBOSClient — the
same call works on both.
Example: (list-workflows client {:workflow-ids ["hello-123" "hello-345"] :workflow-name "bulk-create-opening-child-workflow" :statuses ["PENDING" "ERROR"]})
Query workflows from DBOS with optional filters, returning a vector of
status maps. `queryable` is either a DBOS instance or a DBOSClient — the
same call works on both.
Example:
(list-workflows client
{:workflow-ids ["hello-123" "hello-345"]
:workflow-name "bulk-create-opening-child-workflow"
:statuses ["PENDING" "ERROR"]})(step-info->map si)Convert a StepInfo record to a Clojure map, or nil for nil.
Convert a StepInfo record to a Clojure map, or nil for nil.
(workflow-status->map ws)Convert a WorkflowStatus record to a Clojure map.
Convert a WorkflowStatus record to a Clojure map.
Read-side of DBOS, satisfied by both a DBOS instance and a DBOSClient.
Read-side of DBOS, satisfied by both a DBOS instance and a DBOSClient.
(-get-workflow-status this workflow-id)(-list-workflow-steps this workflow-id)(-list-workflows this input)cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |