From de9e524b69f60ea68873b8f192475a448a17cce5 Mon Sep 17 00:00:00 2001 From: sukaryo-heilscher Date: Tue, 31 Mar 2026 13:00:57 -1000 Subject: [PATCH 1/2] Testing which Dag parameters are necessary. --- wfcommons/wfbench/translator/airflow.py | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/wfcommons/wfbench/translator/airflow.py b/wfcommons/wfbench/translator/airflow.py index e8c9d9db..83b1dbd5 100644 --- a/wfcommons/wfbench/translator/airflow.py +++ b/wfcommons/wfbench/translator/airflow.py @@ -64,12 +64,13 @@ def translate(self, output_folder: pathlib.Path, name: Optional[str] = None) -> with DAG( "{name}", description="airflow translation of a wfcommons instance", - schedule="0 0 * * *", - start_date=datetime(2021, 1, 1), + catchup=False, tags=["wfcommons"], ) as dag: """ +# schedule="0 0 * * *", +# start_date=datetime(2021, 1, 1), self._prep_commands(output_folder) @@ -77,12 +78,13 @@ def translate(self, output_folder: pathlib.Path, name: Optional[str] = None) -> self.script += f""" {self._sanitize_varname(task.task_id)} = BashOperator( task_id="{task.task_id}", - depends_on_past=False, bash_command='{self.task_commands[task.task_id]}', - env={{"AIRFLOW_HOME": os.environ["AIRFLOW_HOME"]}}, - retries=3, ) """ +# depends_on_past=False, +# env={{"AIRFLOW_HOME": os.environ["AIRFLOW_HOME"]}}, +# retries=3, + for task in self.tasks.values(): # Comma-separated list of the task's parents parents = ", ".join(map(self._sanitize_varname, self.task_parents[task.task_id])) From c8775f99d00dd15c7a18efe1f111b97009163af0 Mon Sep 17 00:00:00 2001 From: sukaryo-heilscher Date: Tue, 31 Mar 2026 13:24:11 -1000 Subject: [PATCH 2/2] Testing cutting even more from the Dag and removed commented code. --- wfcommons/wfbench/translator/airflow.py | 9 --------- 1 file changed, 9 deletions(-) diff --git a/wfcommons/wfbench/translator/airflow.py b/wfcommons/wfbench/translator/airflow.py index 83b1dbd5..47570d8d 100644 --- a/wfcommons/wfbench/translator/airflow.py +++ b/wfcommons/wfbench/translator/airflow.py @@ -41,8 +41,6 @@ def __init__(self, self.script = f""" from __future__ import annotations -import os -from datetime import datetime from airflow.models.dag import DAG from airflow.operators.bash import BashOperator @@ -64,13 +62,9 @@ def translate(self, output_folder: pathlib.Path, name: Optional[str] = None) -> with DAG( "{name}", description="airflow translation of a wfcommons instance", - - catchup=False, tags=["wfcommons"], ) as dag: """ -# schedule="0 0 * * *", -# start_date=datetime(2021, 1, 1), self._prep_commands(output_folder) @@ -81,9 +75,6 @@ def translate(self, output_folder: pathlib.Path, name: Optional[str] = None) -> bash_command='{self.task_commands[task.task_id]}', ) """ -# depends_on_past=False, -# env={{"AIRFLOW_HOME": os.environ["AIRFLOW_HOME"]}}, -# retries=3, for task in self.tasks.values(): # Comma-separated list of the task's parents