@radzor/workflow-engine

Define and execute multi-step workflows with branching, parallel execution, and error handling. Supports conditional logic, retries, and workflow persistence for complex orchestration scenarios.

Automationv0.1.0typescriptpythonServerworkfloworchestrationautomationpipelinebranchingstepsby Radzor

Install

View source on GitHub →

$npx radzor@latest add workflow-engine

⚠ Constraints: Workflows are stored in-memory; state is lost on process restart. Steps run sequentially by default; use parallel groups for concurrency. Each step handler receives the aggregated output of prior steps.

Inputs

Name	Type	Default	Description
maxConcurrency	number	5	Maximum number of parallel steps that can run simultaneously.
defaultTimeout	number	30000	Default timeout in milliseconds for each step.
retryAttempts	number	0	Default number of retry attempts for failed steps.

maxConcurrencynumber

Maximum number of parallel steps that can run simultaneously.

default: 5

defaultTimeoutnumber

Default timeout in milliseconds for each step.

default: 30000

retryAttemptsnumber

{ "llm": { "constraints": "Workflows are stored in-memory; state is lost on process restart. Steps run sequentially by default; use parallel groups for concurrency. Each step handler receives the aggregated output of prior steps.", "usageExamples": "llm/examples.md", "integrationPrompt": "llm/integration.md" }, "name": "@radzor/workflow-engine", "tags": [ "workflow", "orchestration", "automation", "pipeline", "branching", "steps" ], "events": [ { "name": "onStepComplete", "payload": { "output": "unknown", "stepId": "string", "duration": "number", "stepName": "string", "workflowId": "string" }, "description": "Fired when an individual step finishes successfully." }, { "name": "onWorkflowComplete", "payload": { "status": "string", "duration": "number", "workflowId": "string" }, "description": "Fired when the entire workflow finishes." }, { "name": "onWorkflowFailed", "payload": { "error": "string", "stepId": "string", "workflowId": "string" }, "description": "Fired when a workflow fails due to a step error." } ], "inputs": [ { "name": "maxConcurrency", "type": "number", "default": 5, "required": false, "description": "Maximum number of parallel steps that can run simultaneously." }, { "name": "defaultTimeout", "type": "number", "default": 30000, "required": false, "description": "Default timeout in milliseconds for each step." }, { "name": "retryAttempts", "type": "number", "default": 0, "required": false, "description": "Default number of retry attempts for failed steps." } ], "radzor": "1.0.0", "actions": [ { "name": "defineWorkflow", "params": [ { "name": "definition", "type": "WorkflowDefinition", "description": "Workflow definition with steps, branches, and configuration." } ], "returns": "string", "description": "Register a workflow definition and return its ID." }, { "name": "execute", "params": [ { "name": "workflowId", "type": "string", "description": "ID of the registered workflow to execute." }, { "name": "input", "type": "Record<string, unknown>", "required": false, "description": "Input data passed to the first step." } ], "returns": "Promise<WorkflowResult>", "description": "Execute a registered workflow with optional input data." }, { "name": "pause", "params": [ { "name": "executionId", "type": "string", "description": "ID of the running execution to pause." } ], "returns": "void", "description": "Pause a running workflow execution." }, { "name": "resume", "params": [ { "name": "executionId", "type": "string", "description": "ID of the paused execution to resume." } ], "returns": "Promise<WorkflowResult>", "description": "Resume a paused workflow execution." }, { "name": "cancel", "params": [ { "name": "executionId", "type": "string", "description": "ID of the execution to cancel." } ], "returns": "void", "description": "Cancel a running or paused workflow execution." }, { "name": "getStatus", "params": [ { "name": "executionId", "type": "string", "description": "ID of the execution to inspect." } ], "returns": "ExecutionStatus", "description": "Get the current status of a workflow execution." } ], "outputs": [ { "name": "workflowResult", "type": "WorkflowResult", "fields": [ { "name": "status", "type": "'completed' | 'failed' | 'cancelled'", "description": "Terminal status of the workflow." }, { "name": "steps", "type": "StepResult[]", "description": "Ordered list of step results with status and output." }, { "name": "output", "type": "Record<string, unknown>", "description": "Aggregated output from all completed steps." }, { "name": "duration", "type": "number", "description": "Total execution time in milliseconds." } ], "description": "Final result of a completed workflow execution." } ], "runtime": "server", "version": "0.1.0", "category": "automation", "languages": [ "typescript", "python" ], "description": "Define and execute multi-step workflows with branching, parallel execution, and error handling. Supports conditional logic, retries, and workflow persistence for complex orchestration scenarios.", "dependencies": { "radzor": [], "packages": {} }, "composability": { "connectsTo": [ { "event": "onWorkflowFailed", "description": "Alert team on workflow failure", "compatibleWith": [ "@radzor/error-tracker.action.captureMessage.message", "@radzor/slack-bot.action.sendMessage.text", "@radzor/notification-hub.action.send.body" ] }, { "event": "onWorkflowComplete", "description": "Notify on workflow completion", "compatibleWith": [ "@radzor/slack-bot.action.sendMessage.text", "@radzor/email-send.action.send.message" ] }, { "output": "workflowResult", "mapField": "status", "compatibleWith": [ "@radzor/csv-export.action.generate.data" ] } ] } }

@radzor/workflow-engine

Install

Inputs

Outputs

Actions

Events

Composability

radzor.manifest.json