# Runs Client

Bases: `BaseRestClient`

The runs client is a client for interacting with task and workflow runs within Hatchet.

Methods:

Name, Description

`get`, Get workflow run details for a given workflow run ID.
`aio_get`, Get workflow run details for a given workflow run ID.
`get_status`, Get workflow run status for a given workflow run ID.
`aio_get_status`, Get workflow run status for a given workflow run ID.
`list`, List task runs according to a set of filters.
`aio_list`, List task runs according to a set of filters.
`create`, Trigger a new workflow run.
`aio_create`, Trigger a new workflow run.
`replay`, Replay a task or workflow run.
`aio_replay`, Replay a task or workflow run.
`bulk_replay`, Replay task or workflow runs in bulk, according to a set of filters.
`aio_bulk_replay`, Replay task or workflow runs in bulk, according to a set of filters.
`cancel`, Cancel a task or workflow run.
`aio_cancel`, Cancel a task or workflow run.
`bulk_cancel`, Cancel task or workflow runs in bulk, according to a set of filters.
`aio_bulk_cancel`, Cancel task or workflow runs in bulk, according to a set of filters.
`get_result`, Get the result of a workflow run by its external ID.
`aio_get_result`, Get the result of a workflow run by its external ID.
`get_run_ref`, Get a reference to a workflow run.
`get_task_run`, Get task run details for a given task run ID.
`aio_get_task_run`, Get task run details for a given task run ID.
`bulk_cancel_by_filters_with_pagination`, Cancel runs matching the specified filters in chunks.
`bulk_replay_by_filters_with_pagination`, Replay runs matching the specified filters in chunks.
`aio_bulk_cancel_by_filters_with_pagination`, Cancel runs matching the specified filters in chunks.
`aio_bulk_replay_by_filters_with_pagination`, Replay runs matching the specified filters in chunks.
`subscribe_to_stream`

### Functions

#### `get`

Get workflow run details for a given workflow run ID.

Parameters:

Name, Type, Description, Default

`workflow_run_id`, `str`, The ID of the workflow run to retrieve details for., _required_

Returns:

Type, Description

`V1WorkflowRunDetails`, Workflow run details for the specified workflow run ID.

#### `aio_get`

Get workflow run details for a given workflow run ID.

Parameters:

Name, Type, Description, Default

`workflow_run_id`, `str`, The ID of the workflow run to retrieve details for., _required_

Returns:

Type, Description

`V1WorkflowRunDetails`, Workflow run details for the specified workflow run ID.

#### `get_status`

Get workflow run status for a given workflow run ID.

Parameters:

Name, Type, Description, Default

`workflow_run_id`, `str`, The ID of the workflow run to retrieve details for., _required_

Returns:

Type, Description

`V1TaskStatus`, The task status

#### `aio_get_status`

Get workflow run status for a given workflow run ID.

Parameters:

Name, Type, Description, Default

`workflow_run_id`, `str`, The ID of the workflow run to retrieve details for., _required_

Returns:

Type, Description

`V1TaskStatus`, The task status

#### `list`

List task runs according to a set of filters.

Parameters:

Name, Type, Description, Default

`since`, `datetime \, None`, The start time for filtering task runs., `None`
`only_tasks`, `bool`, Whether to only list task runs., `False`
`offset`, `int \, None`, The offset for pagination., `None`
`limit`, `int \, None`, The maximum number of task runs to return., `None`
`statuses`, `list[V1TaskStatus] \, None`, The statuses to filter task runs by., `None`
`until`, `datetime \, None`, The end time for filtering task runs., `None`
`additional_metadata`, `dict[str, str] \, None`, Additional metadata to filter task runs by., `None`
`workflow_ids`, `list[str] \, None`, The workflow IDs to filter task runs by., `None`
`worker_id`, `str \, None`, The worker ID to filter task runs by., `None`
`parent_task_external_id`, `str \, None`, The parent task external ID to filter task runs by., `None`
`triggering_event_external_id`, `str \, None`, The event id that triggered the task run., `None`
`include_payloads`, `bool`, Whether to include payloads in the response., `True`

Returns:

Type, Description

`V1TaskSummaryList`, A list of task runs matching the specified filters.

#### `aio_list`

List task runs according to a set of filters.

Parameters:

Name, Type, Description, Default

`since`, `datetime \, None`, The start time for filtering task runs., `None`
`only_tasks`, `bool`, Whether to only list task runs., `False`
`offset`, `int \, None`, The offset for pagination., `None`
`limit`, `int \, None`, The maximum number of task runs to return., `None`
`statuses`, `list[V1TaskStatus] \, None`, The statuses to filter task runs by., `None`
`until`, `datetime \, None`, The end time for filtering task runs., `None`
`additional_metadata`, `dict[str, str] \, None`, Additional metadata to filter task runs by., `None`
`workflow_ids`, `list[str] \, None`, The workflow IDs to filter task runs by., `None`
`worker_id`, `str \, None`, The worker ID to filter task runs by., `None`
`parent_task_external_id`, `str \, None`, The parent task external ID to filter task runs by., `None`
`triggering_event_external_id`, `str \, None`, The event id that triggered the task run., `None`
`include_payloads`, `bool`, Whether to include payloads in the response., `True`

Returns:

Type, Description

`V1TaskSummaryList`, A list of task runs matching the specified filters.

#### `create`

Trigger a new workflow run.

IMPORTANT: It's preferable to use `Workflow.run` (and similar) to trigger workflows if possible. This method is intended to be an escape hatch. For more details, see [the documentation](../../../sdk/python/runnables#workflow).

Parameters:

Name, Type, Description, Default

`workflow_name`, `str`, The name of the workflow to trigger., _required_
`input`, `JSONSerializableMapping`, The input data for the workflow run., _required_
`additional_metadata`, `JSONSerializableMapping \, None`, Additional metadata associated with the workflow run., `None`
`priority`, `int \, None`, The priority of the workflow run., `None`

Returns:

Type, Description

`V1WorkflowRunDetails`, The details of the triggered workflow run.

#### `aio_create`

Trigger a new workflow run.

IMPORTANT: It's preferable to use `Workflow.run` (and similar) to trigger workflows if possible. This method is intended to be an escape hatch. For more details, see [the documentation](../../../sdk/python/runnables#workflow).

Parameters:

Name, Type, Description, Default

`workflow_name`, `str`, The name of the workflow to trigger., _required_
`input`, `JSONSerializableMapping`, The input data for the workflow run., _required_
`additional_metadata`, `JSONSerializableMapping \, None`, Additional metadata associated with the workflow run., `None`
`priority`, `int \, None`, The priority of the workflow run., `None`

Returns:

Type, Description

`V1WorkflowRunDetails`, The details of the triggered workflow run.

#### `replay`

Replay a task or workflow run.

Parameters:

Name, Type, Description, Default

`run_id`, `str`, The external ID of the task or workflow run to replay., _required_

Returns:

Type, Description

`None`, None

#### `aio_replay`

Replay a task or workflow run.

Parameters:

Name, Type, Description, Default

`run_id`, `str`, The external ID of the task or workflow run to replay., _required_

Returns:

Type, Description

`None`, None

#### `bulk_replay`

Replay task or workflow runs in bulk, according to a set of filters.

Parameters:

Name, Type, Description, Default

`opts`, `BulkCancelReplayOpts`, Options for bulk replay, including filters and IDs., _required_

Returns:

Type, Description

`None`, None

#### `aio_bulk_replay`

Replay task or workflow runs in bulk, according to a set of filters.

Parameters:

Name, Type, Description, Default

`opts`, `BulkCancelReplayOpts`, Options for bulk replay, including filters and IDs., _required_

Returns:

Type, Description

`None`, None

#### `cancel`

Cancel a task or workflow run.

Parameters:

Name, Type, Description, Default

`run_id`, `str`, The external ID of the task or workflow run to cancel., _required_

Returns:

Type, Description

`None`, None

#### `aio_cancel`

Cancel a task or workflow run.

Parameters:

Name, Type, Description, Default

`run_id`, `str`, The external ID of the task or workflow run to cancel., _required_

Returns:

Type, Description

`None`, None

#### `bulk_cancel`

Cancel task or workflow runs in bulk, according to a set of filters.

Parameters:

Name, Type, Description, Default

`opts`, `BulkCancelReplayOpts`, Options for bulk cancel, including filters and IDs., _required_

Returns:

Type, Description

`None`, None

#### `aio_bulk_cancel`

Cancel task or workflow runs in bulk, according to a set of filters.

Parameters:

Name, Type, Description, Default

`opts`, `BulkCancelReplayOpts`, Options for bulk cancel, including filters and IDs., _required_

Returns:

Type, Description

`None`, None

#### `get_result`

Get the result of a workflow run by its external ID.

Parameters:

Name, Type, Description, Default

`run_id`, `str`, The external ID of the workflow run to retrieve the result for., _required_

Returns:

Type, Description

`JSONSerializableMapping`, The result of the workflow run.

#### `aio_get_result`

Get the result of a workflow run by its external ID.

Parameters:

Name, Type, Description, Default

`run_id`, `str`, The external ID of the workflow run to retrieve the result for., _required_

Returns:

Type, Description

`JSONSerializableMapping`, The result of the workflow run.

#### `get_run_ref`

Get a reference to a workflow run.

Parameters:

Name, Type, Description, Default

`workflow_run_id`, `str`, The ID of the workflow run to get a reference to., _required_

Returns:

Type, Description

`WorkflowRunRef`, A reference to the specified workflow run.

#### `get_task_run`

Get task run details for a given task run ID.

Parameters:

Name, Type, Description, Default

`task_run_id`, `str`, The ID of the task run to retrieve details for., _required_

Returns:

Type, Description

`V1TaskSummary`, Task run details for the specified task run ID.

#### `aio_get_task_run`

Get task run details for a given task run ID.

Parameters:

Name, Type, Description, Default

`task_run_id`, `str`, The ID of the task run to retrieve details for., _required_

Returns:

Type, Description

`V1TaskSummary`, Task run details for the specified task run ID.

#### `bulk_cancel_by_filters_with_pagination`

Cancel runs matching the specified filters in chunks.

The motivation for this method is to provide an easy way to perform bulk operations by filters over a larger number of runs than the API would normally be able to handle, with automatic pagination and chunking to help limit the pressure on the API.

This method first pulls the IDs of the runs from the API, and then feeds them back to the API in chunks.

Parameters:

Name, Type, Description, Default

`sleep_time`, `int`, The time to sleep between processing chunks, in seconds., `3`
`chunk_size`, `int`, The maximum number of run IDs to process in each chunk., `500`
`since`, `datetime \, None`, The start time for filtering runs., `None`
`until`, `datetime \, None`, The end time for filtering runs., `None`
`statuses`, `list[V1TaskStatus] \, None`, The statuses to filter runs by., `None`
`additional_metadata`, `dict[str, str] \, None`, Additional metadata to filter runs by., `None`
`workflow_ids`, `list[str] \, None`, The workflow IDs to filter runs by., `None`

#### `bulk_replay_by_filters_with_pagination`

Replay runs matching the specified filters in chunks.

The motivation for this method is to provide an easy way to perform bulk operations by filters over a larger number of runs than the API would normally be able to handle, with automatic pagination and chunking to help limit the pressure on the API.

This method first pulls the IDs of the runs from the API, and then feeds them back to the API in chunks.

Parameters:

Name, Type, Description, Default

`sleep_time`, `int`, The time to sleep between processing chunks, in seconds., `3`
`chunk_size`, `int`, The maximum number of run IDs to process in each chunk., `500`
`since`, `datetime \, None`, The start time for filtering runs., `None`
`until`, `datetime \, None`, The end time for filtering runs., `None`
`statuses`, `list[V1TaskStatus] \, None`, The statuses to filter runs by., `None`
`additional_metadata`, `dict[str, str] \, None`, Additional metadata to filter runs by., `None`
`workflow_ids`, `list[str] \, None`, The workflow IDs to filter runs by., `None`

#### `aio_bulk_cancel_by_filters_with_pagination`

Cancel runs matching the specified filters in chunks.

The motivation for this method is to provide an easy way to perform bulk operations by filters over a larger number of runs than the API would normally be able to handle, with automatic pagination and chunking to help limit the pressure on the API.

This method first pulls the IDs of the runs from the API, and then feeds them back to the API in chunks.

Parameters:

Name, Type, Description, Default

`sleep_time`, `int`, The time to sleep between processing chunks, in seconds., `3`
`chunk_size`, `int`, The maximum number of run IDs to process in each chunk., `500`
`since`, `datetime \, None`, The start time for filtering runs., `None`
`until`, `datetime \, None`, The end time for filtering runs., `None`
`statuses`, `list[V1TaskStatus] \, None`, The statuses to filter runs by., `None`
`additional_metadata`, `dict[str, str] \, None`, Additional metadata to filter runs by., `None`
`workflow_ids`, `list[str] \, None`, The workflow IDs to filter runs by., `None`

#### `aio_bulk_replay_by_filters_with_pagination`

Replay runs matching the specified filters in chunks.

The motivation for this method is to provide an easy way to perform bulk operations by filters over a larger number of runs than the API would normally be able to handle, with automatic pagination and chunking to help limit the pressure on the API.

This method first pulls the IDs of the runs from the API, and then feeds them back to the API in chunks.

Parameters:

Name, Type, Description, Default

`sleep_time`, `int`, The time to sleep between processing chunks, in seconds., `3`
`chunk_size`, `int`, The maximum number of run IDs to process in each chunk., `500`
`since`, `datetime \, None`, The start time for filtering runs., `None`
`until`, `datetime \, None`, The end time for filtering runs., `None`
`statuses`, `list[V1TaskStatus] \, None`, The statuses to filter runs by., `None`
`additional_metadata`, `dict[str, str] \, None`, Additional metadata to filter runs by., `None`
`workflow_ids`, `list[str] \, None`, The workflow IDs to filter runs by., `None`

#### `subscribe_to_stream`