Skip to content

Instantly share code, notes, and snippets.

@sawmonaco
Created February 14, 2023 19:33
Show Gist options
  • Save sawmonaco/6a260e8704a2eba1a856f9d4db716f70 to your computer and use it in GitHub Desktop.
Save sawmonaco/6a260e8704a2eba1a856f9d4db716f70 to your computer and use it in GitHub Desktop.
{
"createTime": 1676389863059,
"updateTime": 1676395475651,
"name": "test_concurrency",
"description": "Test out concurrency of stopping the workflow",
"version": 9,
"tasks": [
{
"name": "dynamic_fork",
"taskReferenceName": "fake_download_complete_fork",
"inputParameters": {
"dynamicTasks": [
{
"name": "dynamic_sleep_task",
"taskReferenceName": "dynamic_sleep_task_0"
},
{
"name": "dynamic_sleep_task",
"taskReferenceName": "dynamic_sleep_task_1"
}
],
"dynamicTasksInput": {
"dynamic_sleep_task_0": {},
"dynamic_sleep_task_1": {}
}
},
"type": "FORK_JOIN_DYNAMIC",
"dynamicForkTasksParam": "dynamicTasks",
"dynamicForkTasksInputParamName": "dynamicTasksInput",
"startDelay": 0,
"optional": false,
"asyncComplete": false
},
{
"name": "join",
"taskReferenceName": "fake_download_complete_join",
"inputParameters": {},
"type": "JOIN",
"startDelay": 0,
"optional": false,
"asyncComplete": false
},
{
"name": "jq_example_task",
"taskReferenceName": "my_jq_example_task",
"inputParameters": {
"key1": {
"value1": [
"a",
"b"
]
},
"key2": {
"value2": [
"c",
"d"
]
},
"queryExpression": "{ key3: (.key1.value1 + .key2.value2) }"
},
"type": "JSON_JQ_TRANSFORM",
"startDelay": 0,
"optional": false,
"asyncComplete": false
}
],
"inputParameters": [],
"outputParameters": {
"data": ""
},
"schemaVersion": 2,
"restartable": true,
"workflowStatusListenerEnabled": false,
"ownerEmail": "example@email.com",
"timeoutPolicy": "ALERT_ONLY",
"timeoutSeconds": 0,
"variables": {},
"inputTemplate": {}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment