Sending Signals to Workflows

You can manage and automate workflows by sending signals to pause, resume, terminate, restart, rerun workflows, and more. Using Conductor SDKs or APIs, you can integrate and programmatically control workflows during production and in case of failure.

Pause workflow

You can pause a workflow to wait for external signals.

Using UI

In the workflow execution page (Executions > Workflow > someWorkflow), select Actions > Pause.

Using API

Use the Pause Workflow API on a running workflow.

Endpoint: PUT /api/workflow/{workflowId}/pause

Using SDK

Java

BulkResponse pauseWorkflow(List<String> workflowIds) throws ApiException

Go

func (e *WorkflowExecutor) Pause(workflowId string) error

Python

WorkflowResourceApi.pause_workflow1(self, workflow_id, **kwargs)

C#

void WorkflowResourceApi.PauseWorkflow(string workflowId)

JavaScript

WorkflowExecutor.pauseWorkflow(
    workflowId: string,
): CancelablePromise<any>

Typescript

WorkflowExecutor.pauseWorkflow(
    workflowId: string,
): CancelablePromise<any>

Clojure

(workflow-resource/pause-workflow [options workflow-id])

Resume workflow

Once an external signal is received, you can resume the paused workflow.

Using UI

In the workflow execution page (Executions > Workflow > someWorkflow), select Actions > Resume.

Using API

Use the Resume Workflow API on a paused workflow.

Endpoint: PUT /api/workflow/{workflowId}/resume

Using SDK

Java

BulkResponse resumeWorkflow(List<String> workflowIds) throws ApiException

Go

func (e *WorkflowExecutor) Resume(workflowId string) error

Python

WorkflowResourceApi.resume_workflow1(self, workflow_id, **kwargs)

C#

void WorkflowResourceApi.ResumeWorkflow(string workflowId)

JavaScript

WorkflowExecutor.resume(
    workflowId: string,
): CancelablePromise<any>

Typescript

WorkflowExecutor.resume(
    workflowId: string,
): CancelablePromise<any>

Clojure

(workflow-resource/resume-workflow [options workflow-id])

Restart workflow

If a workflow execution fails for any reason and enters a terminal state, you can restart it from the beginning. There are two options for restarting workflows:

• Restart with Current Definitions—Restart using the same workflow definition that was referenced in the initial execution. This is useful if the workflow definition has changed and the original definition needs to be retained.
• Restart with Latest Definitions—Restart using the latest workflow definition and version. If you’ve changed the definition, you can use this option to rerun the execution with the latest version.

note

When restarting workflows, the same inputs will be used. To use different workflow inputs, rerun the workflow instead.

Using UI

In the workflow execution page (Executions > Workflow > someTerminalWorkflow), select Actions > Restart with current definitions or Restart with latest definitions.

Using API

Use the Restart Workflow API on a terminal workflow to restart the workflow from the beginning with the same input.

Endpoint: POST /api/workflow/{workflowId}/restart

Using SDK

Java

BulkResponse restartWorkflow(List<String> workflowIds, Boolean useLatestDefinitions) throws ApiException

Go

func (e *WorkflowExecutor) Restart(workflowId string, useLatestDefinition bool) error

Python

WorkflowResourceApi.restart1(self, workflow_id, **kwargs)

C#

void WorkflowResourceApi.Restart(string workflowId, bool? useLatestDefinitions = null)

JavaScript

WorkflowExecutor.restart(
    workflowId: string,
    useLatestDefinitions: boolean,
): CancelablePromise<void>

Typescript

WorkflowExecutor.restart(
    workflowId: string,
    useLatestDefinitions: boolean,
): CancelablePromise<void>

Clojure

(workflow-resource/restart-workflow [options workflow-id])

Rerun workflow

You can rerun a terminal workflow from the start if you need to change the workflow inputs, correlation ID, or task-to-domain mapping. The workflow (execution) ID from the original run will be retained.

Using UI

note

In the UI, there is no option to rerun the workflow using the same workflow (execution) ID. However, you can rerun it by creating a new execution instance.

In the workflow execution page (Executions > Workflow > someTerminalWorkflow), select Actions > Re-run Workflow. You will be redirected to the Run Workflow page, where you can update the workflow inputs, correlation ID, and task-to-domain mapping to run a new workflow instance.

Using API

Use the Rerun Workflow API to rerun the workflow from the beginning with updated inputs.

Endpoint: POST /api/workflow/{workflowId}/rerun

Using SDK

Java

String rerunWorkflow(String workflowId, RerunWorkflowRequest rerunWorkflowRequest)

Go

func (e *WorkflowExecutor) ReRun(workflowId string, reRunRequest model.RerunWorkflowRequest) (id string, error error)

Python

WorkflowResourceApi.rerun(self, body, workflow_id, **kwargs)

C#

string WorkflowResourceApi.Rerun(RerunWorkflowRequest body, string workflowId)

JavaScript

WorkflowExecutor.rerun(
    workflowId: string,
    requestBody: RerunWorkflowRequest,
): CancelablePromise<string>

Typescript

WorkflowResourceService.rerun(
    workflowId: string,
    requestBody: RerunWorkflowRequest,
): CancelablePromise<string>

Clojure

(workflow-resource/rerun-workflow [options workflow-id rerun-wf-request])

Rerun workflow from task

In certain cases, you may wish to rerun an ongoing or terminal workflow from a specific task instead.

Using UI

In the workflow execution page (Executions > Workflow > someWorkflow), select a task in the visual diagram, then select Re-Run from Task. The task will be rerun, and the previous attempt(s) will be marked as CANCELED.

note

If you need to provide updated task inputs, use the API instead.

Using API

Use the Rerun Workflow API to rerun the workflow from a specific task, with the option to provide updated task inputs.

Endpoint: POST /api/workflow/{workflowId}/rerun

Using SDK

Java

String rerunWorkflow(String workflowId, RerunWorkflowRequest rerunWorkflowRequest)

Go

func (e *WorkflowExecutor) ReRun(workflowId string, reRunRequest model.RerunWorkflowRequest) (id string, error error)

Python

WorkflowResourceApi.rerun(self, body, workflow_id, **kwargs)

C#

string WorkflowResourceApi.Rerun(RerunWorkflowRequest body, string workflowId)

JavaScript

WorkflowExecutor.rerun(
    workflowId: string,
    requestBody: RerunWorkflowRequest,
): CancelablePromise<string>

Typescript

WorkflowResourceService.rerun(
    workflowId: string,
    requestBody: RerunWorkflowRequest,
): CancelablePromise<string>

Clojure

(workflow-resource/rerun-workflow [options workflow-id rerun-wf-request])

Retry from failed task

If the workflow fails, you can retry it from its last failed task.

Using UI

In the workflow execution page (Executions > Workflow > someWorkflow), select Actions > Retry - from failed task. The task will be rerun, and the previous attempt(s) will be marked as CANCELED.

Using API

Use the Retry Failed Workflow API to retry the workflow from its last failed task.

Endpoint: POST /api/workflow/{workflowId}/retry

Using SDK

Java

BulkResponse retryWorkflow(List<String> workflowIds) throws ApiException

Go

func (e *WorkflowExecutor) Retry(workflowId string, resumeSubworkflowTasks bool) error

Python

WorkflowResourceApi.retry1(self, workflow_id, **kwargs)

C#

void WorkflowResourceApi.Retry(string workflowId, bool? resumeSubworkflowTasks = null)

JavaScript

WorkflowExecutor.retry(
    workflowId: string,
    resumeSubworkflowTasks: boolean,
): CancelablePromise<void>

Typescript

WorkflowExecutor.retry(
    workflowId: string,
    resumeSubworkflowTasks: boolean,
): CancelablePromise<void>

Clojure

(workflow-resource/retry-last-failed-task [options workflow-id resume-subworkflow-tasks])

Update task status

In some cases, you may need to update the task status in an ongoing workflow with a signal, such as updating the status of a signal-type Wait task.

Using UI

1. In the workflow execution page (Executions > Workflow > someWorkflow), select a task in the visual diagram.
2. In the Summary tab, select a status in the Update task field.
3. (Optional) Add the task outputs in the Code field.
4. Select Update.

Once the task is updated via UI,the worker is automatically set to conductor-ui, providing better traceability for manual overrides.

Using API

Use the Update Task Status in Workflow API to update the task status to one of the following options:

• FAILED
• FAILED_WITH_TERMINAL_ERROR
• COMPLETED

You can also provide the task output in the request body.

Endpoint: POST /api/tasks/{workflowId}/{taskRefName}/{status}

Using SDK

Java

String OrkesTaskClient.updateTaskByRefName(Map<String, Object> output, String workflowId, String taskRefName, String status) throws ApiException

Go

func (*WorkflowExecutor) UpdateTaskByRefName(taskRefName string, workflowInstanceId string, status model.TaskResultStatus, output interface{}) error

Python

TaskResourceApi.update_task1(taskOutput, workflow_id, task_ref_name, status, **kwargs)

C#

string TaskResourceApi.UpdateTask(Dictionary<string, Object> taskOutput, string workflowId, string taskRefName, string status, string workerid = null)

JavaScript

TaskResourceService.updateTask(
    workflowId: string,
    taskRefName: string,
    status: 'IN_PROGRESS' | 'FAILED' | 'FAILED_WITH_TERMINAL_ERROR' | 'COMPLETED',
    taskOutput: Record<string, any>,
): CancelablePromise<string>

Typescript

TaskResourceService.updateTask(
    workflowId: string,
    taskRefName: string,
    status: 'IN_PROGRESS' | 'FAILED' | 'FAILED_WITH_TERMINAL_ERROR' | 'COMPLETED',
    taskOutput: Record<string, any>,
): CancelablePromise<string>

Clojure

(task-resource/update-task-by-reference-name options workflow-id task-reference-name status update-req)

Terminate workflow

In some cases, you may need to terminate the workflow with a signal. For example, if a user terminates an ongoing indexing process.

Using UI

In the workflow execution page (Executions > Workflow > someWorkflow), select Actions > Terminate.

Using API

Use the Terminate Workflow API to terminate an ongoing workflow.

Endpoint: DELETE /api/workflow/{workflowId}

Using SDK

Java

void terminateWorkflow(String workflowId, String reason)

Go

func (e *WorkflowExecutor) Terminate(workflowId string, reason string) error

Python

WorkflowResourceApi.terminate1(self, workflow_id, **kwargs)

C#

void WorkflowResourceApi.Terminate(string workflowId, string reason = null, bool? triggerFailureWorkflow = null)

JavaScript

WorkflowExecutor.terminate(
    workflowId: string,
    reason: string,
): CancelablePromise<any>

Typescript

WorkflowExecutor.terminate(
    workflowId: string,
    reason: string,
): CancelablePromise<any>

Clojure

(workflow-resource/terminate-workflow [options workflow-id & args])