Skip to main content

Example 1: A simple workflow

Workflow definition#


{  "workflow_id": "example1",  "config": {},  "tasks": [    {      "id": "1",      "execution_configurations" : [        {          "function_def_id" : "my_lambda_function1",          "priority" : 1        }      ],      "successors": [        "2",        "3",        "4"      ],      "properties": {        "position": "start"      }    },    {      "id": "2",      "execution_configurations" : [        {          "function_def_id" : "my_lambda_function2",          "priority" : 1        }      ],      "successors": [],      "properties": {        "static_input": {          "msg": "static input message"        }      }    },    {      "id": "3",      "execution_configurations" : [        {          "function_def_id" : "my_lambda_function3",          "priority" : 1        }      ],      "successors": [        "4"      ],      "properties": {        "delay": 10      }    },    {      "id": "4",      "execution_configurations" : [        {          "function_def_id" : "my_lambda_function4",          "priority" : 1        }      ],
      "successors": []    }  ]}

DAG Representation#

Example 1