Perform dry run

viaduct-ai · Jun 4, 2021 · 880db4b · 880db4b
1 parent 3e0b8a2
commit 880db4b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dump_dags.py b/dump_dags.py
@@ -12,6 +12,7 @@ def dump_dags(output_base_path):
         with open(os.path.join(output_base_path, dag_id), 'w') as outfile:
             adj = defaultdict(list)  # Adjacency list of DAG.
             for task in dag.tasks:
+                task.dry_run()  # Perform dry run to validate template fields.
                 for upstream_task_id in task.upstream_task_ids:
                     adj[upstream_task_id].append(task.task_id)