fork_from_failure
Fork failed workflows from a chosen step or last failure to re-execute after a fix, reusing recorded outputs of prior steps.
Instructions
Fork multiple failed workflows from a specific point.
Creates new workflows that re-execute from a chosen point, reusing the recorded outputs of all prior steps. Useful for retrying a batch of failed workflows after deploying a fix.
IMPORTANT: You must set exactly one of from_last_failure, from_last_step, from_step, or from_step_name.
Args: application_name (string, required): Name of the DBOS application workflow_ids (array of strings, required): IDs of the workflows to fork application_version (string, optional): Application version for the new workflows (defaults to current version) queue_name (string, optional): Enqueue the forked workflows onto this queue queue_partition_key (string, optional): Partition key for the queue from_last_failure (bool, optional): Fork from the last failed step (default: false) from_last_step (bool, optional): Fork from the last executed step (default: false) from_step (int, optional): Fork from this specific step number from_step_name (string, optional): Fork from the step with this function name
Returns: workflow_ids (array of strings): IDs of the newly created forked workflows count (int): Number of workflows forked
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| from_step | No | ||
| queue_name | No | ||
| workflow_ids | Yes | ||
| from_last_step | No | ||
| from_step_name | No | ||
| application_name | Yes | ||
| from_last_failure | No | ||
| application_version | No | ||
| queue_partition_key | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||