Kinesin/daggy
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Updating example dag

Browse Source
This commit is contained in:
Ian Roddis
2022-01-04 17:03:42 -04:00
parent f1479a72d9
commit 64a85cd996
1 changed files with 81 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

90
examples/sample_dag.json
View File

@@ -1,11 +1,83 @@
{
"tag": "testdag",
"tasks": {
"A": { "job": { "command": [ "/usr/bin/echo", "hello" ], "cores": "1", "memoryMB": "100" }, "children": [ "b", "c", "d" ]},
"b": { "job": { "command": [ "/usr/bin/sleep", "2" ], "cores": "1", "memoryMB": "100" }, "children": [ "d" ]},
"c": { "job": { "command": [ "/usr/bin/echo", "hello" ], "cores": "1", "memoryMB": "100" }, "children": [ "e", "f" ]},
"d": { "job": { "command": [ "/usr/bin/echo", "hello" ], "cores": "1", "memoryMB": "100" }, "children": [ "f" ]},
"e": { "job": { "command": [ "/usr/bin/echo", "hello" ], "cores": "1", "memoryMB": "100" }, "children": [ "f" ]},
"f": { "job": { "command": [ "/usr/bin/echo", "hello" ], "cores": "1", "memoryMB": "100" }}
}
"tag": "testdag",
"parameters": {
"DATES": [
"2022-01-01",
"2022-01-02"
]
},
"tasks": {
"A": {
"job": {
"command": [
"/usr/bin/echo",
"A",
"{{DATE}}"
]
},
"children": [
"b",
"c",
"d"
]
},
"b": {
"job": {
"command": [
"/usr/bin/sleep",
"B",
"{{DATE}"
]
},
"children": [
"d"
]
},
"c": {
"job": {
"command": [
"/usr/bin/echo",
"C",
"{{DATE}"
]
},
"children": [
"e",
"f"
]
},
"d": {
"job": {
"command": [
"/usr/bin/echo",
"D",
"{{DATE}"
]
},
"children": [
"f"
]
},
"e": {
"job": {
"command": [
"/usr/bin/echo",
"E",
"{{DATE}"
]
},
"children": [
"f"
]
},
"f": {
"job": {
"command": [
"/usr/bin/echo",
"F",
"{{DATE}"
]
}
}
}
}