conductor.workflow-resource — io.orkes/conductor-clojure 0.1.6

delete-workflow clj

(delete-workflow options workflow-id & args)

Takes a options,workflow-id and an optional archive-workflow boolean. Deletes the workflow execution. Returns nil

delete-workflow-with-client clj

(delete-workflow-with-client client workflow-id)

(delete-workflow-with-client client workflow-id archive-workflow)

Takes a client,workflow-id and an optional archive-workflow boolean. Deletes the workflow execution. Returns nil

get-running-workflow clj

(get-running-workflow options wf-name version)

Takes options, workflow-name and a version. Returns a list of running workflow ids

get-running-workflow-with-client clj

(get-running-workflow-with-client client wf-name version)

Takes a client,workflow-name and a version. Returns a list of running workflow ids

get-workflow clj

(get-workflow options workflow-id & args)

Returns a workflow execution for given workflow-id

get-workflow-by-time-period clj

(get-workflow-by-time-period options wf-name version start-time end-time)

Takes options, workflow-name version start-time and end-time (in milliseconds). Returns a list of workflow-ids within that period

get-workflow-by-time-period-with-client clj

(get-workflow-by-time-period-with-client client
                                         wf-name
                                         version
                                         start-time
                                         end-time)

Takes a client, workflow-name version start-time and end-time (in milliseconds). Returns a list of workflow-ids within that period

get-workflow-with-client clj

(get-workflow-with-client client workflow-id)

(get-workflow-with-client client workflow-id include-tasks)

get-workflows clj

(get-workflows options wf-name correlation-id & args)

Takes a options, workflow-name, correlation-id and optional keyword arguments :inclide-closed and :include-tasks Return a list of workflow-executions

get-workflows-with-client clj

(get-workflows-with-client client
                           wf-name
                           correlation-id
                           &
                           {:keys [include-closed include-tasks]
                            :or {include-closed false include-tasks false}})

Takes a client,workflow-name,correlation-id and optional keyword arguments :inclide-closed and :include-tasks Return a list of workflow-executions

pause-workflow clj

(pause-workflow options workflow-id)

Takes options and a workflow-id. Pauses the current workflow. Returns nil

pause-workflow-with-client clj

(pause-workflow-with-client client workflow-id)

Takes a client and a workflow-id. Pauses the current workflow. Returns nil

rerun-workflow clj

(rerun-workflow options workflow-id rerun-wf-request)

rerun-workflow-with-client clj

(rerun-workflow-with-client client workflow-id rerun-wf-request)

restart clj

(restart options workflow-id & args)

restart-with-client clj

(restart-with-client client workflow-id)

(restart-with-client client workflow-id use-latest-definitions)

resume-workflow clj

(resume-workflow options workflow-id)

Takes options and a workflow-id. Resumes a paused workflow. Returns nil

resume-workflow-with-client clj

(resume-workflow-with-client client workflow-id)

Takes a client and a workflow-id. Resumes a paused workflow. Returns nil

retry-last-failed-task clj

(retry-last-failed-task options workflow-id)

retry-last-failed-task-with-client clj

(retry-last-failed-task-with-client client workflow-id)

search clj

(search options query)

search-with-client clj

(search-with-client client query)

skip-task-from-workflow clj

(skip-task-from-workflow options workflow-id task-reference-name)

Takes options a workflow-id and a task-reference-name. Will skip the task. Returns nil

skip-task-from-workflow-with-client clj

(skip-task-from-workflow-with-client client workflow-id task-reference-name)

Takes a client a workflow-id and a task-reference-name. Will skip the task. Returns nil

start-workflow clj

(start-workflow options start-request)

Takes an option map and a start-request map and starts a workflow. Returns the id of a workflow execution

start-workflow-with-client clj

(start-workflow-with-client client start-request)

Takes a client and a start-request map, and starts a workflow

terminate-workflow clj

(terminate-workflow options workflow-id & args)

Terminates a running workflow. given an id and an optional reason

terminate-workflow-with-client clj

(terminate-workflow-with-client client workflow-id)

(terminate-workflow-with-client client workflow-id reason)

Takes a client a workflow-id and an optional reason. will terminate a running workflow

terminate-workflows clj

(terminate-workflows options workflow-ids & args)

Takes an options map and a list of workflow-ids and an optional reason. Terminates workflows in the list. Returns a BulkResponse map with success and failures

terminate-workflows-with-client clj

(terminate-workflows-with-client client workflow-ids)

(terminate-workflows-with-client client workflow-ids reason)

Takes a client and a list of workflow-ids and an optional reason. Terminates workflows in the list. Returns a BulkResponse map with success and failures

workflow-client clj

(workflow-client {:keys [app-key app-secret url]
                  :or {url "http://localhost:8080/api/"}})

Returns an instance of TaskClient. when app-key and app-secret are provided Then returned instance will be Orkes Compatible