Appearance
demo.mega_pipeline
Demo pipeline: validate → allocate (compute+storage) → network → security → deploy (frontend+backend) → checks → notify
Demo DAG: 7 layers, 2 with 2 siblings (allocate_resources, deploy_artifacts).
Overview
| Property | Value |
|---|---|
| Workflow type | Dag |
| Library | Business |
| Version | 1.0 |
Input Schema
| Field | Type | Required | Default | Description |
|---|---|---|---|---|
workflow_run_id | string | No | — | Stamped by parent DAG if nested |
Output Schema
| Field | Type | Required | Default | Description |
|---|---|---|---|---|
workflow_run_id | string | No | — | — |
validate_input | json | No | — | — |
allocate_compute | json | No | — | — |
allocate_storage | json | No | — | — |
provision_network | json | No | — | — |
configure_security | json | No | — | — |
deploy_frontend | json | No | — | — |
deploy_backend | json | No | — | — |
run_checks | json | No | — | — |
notify | json | No | — | — |
failure_reason | string | No | — | — |
failure_type | string | No | — | — |
failed_action | string | No | — | — |
failed_at_state | string | No | — | — |
failed_step | string | No | — | — |
failed_layer | string | No | — | — |
error | string | No | — | — |
error_type | string | No | — | — |
failed_at | string | No | — | — |
DAG Layers
| # | Layer | Steps | Compensation |
|---|---|---|---|
| 1 | validate_input | demo.validate_input | — |
| 2 | allocate_resources | demo.allocate_compute, demo.allocate_storage | — |
| 3 | provision_network | demo.provision_network | — |
| 4 | configure_security | demo.configure_security | — |
| 5 | deploy_artifacts | demo.deploy_frontend, demo.deploy_backend | — |
| 6 | run_checks | demo.run_checks | — |
| 7 | notify | demo.notify | — |
Execution Flow
Sub-workflows
| Sub-workflow | Step name |
|---|---|
demo.validate_input | validate_input |
demo.allocate_compute | allocate_compute |
demo.allocate_storage | allocate_storage |
demo.provision_network | provision_network |
demo.configure_security | configure_security |
demo.deploy_frontend | deploy_frontend |
demo.deploy_backend | deploy_backend |
demo.run_checks | run_checks |
demo.notify | notify |
API Usage
bash
POST /api/workflows/start
Content-Type: application/json
{
"workflow_type": "demo.mega_pipeline",
"initial_data": {
"workflow_run_id": "value"
}
}