From 64a85cd996e54bb47e65615da7e0b3339c557986 Mon Sep 17 00:00:00 2001 From: Ian Roddis Date: Tue, 4 Jan 2022 17:03:42 -0400 Subject: [PATCH] Updating example dag --- examples/sample_dag.json | 90 ++++++++++++++++++++++++++++++++++++---- 1 file changed, 81 insertions(+), 9 deletions(-) diff --git a/examples/sample_dag.json b/examples/sample_dag.json index 5327e08..2b2bbf9 100644 --- a/examples/sample_dag.json +++ b/examples/sample_dag.json @@ -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}" + ] + } + } + } }