Skip to content

Commit c8775f9

Browse files
Testing cutting even more from the Dag and removed commented code.
1 parent de9e524 commit c8775f9

1 file changed

Lines changed: 0 additions & 9 deletions

File tree

wfcommons/wfbench/translator/airflow.py

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,6 @@ def __init__(self,
4141
self.script = f"""
4242
from __future__ import annotations
4343
44-
import os
45-
from datetime import datetime
4644
from airflow.models.dag import DAG
4745
from airflow.operators.bash import BashOperator
4846
@@ -64,13 +62,9 @@ def translate(self, output_folder: pathlib.Path, name: Optional[str] = None) ->
6462
with DAG(
6563
"{name}",
6664
description="airflow translation of a wfcommons instance",
67-
68-
catchup=False,
6965
tags=["wfcommons"],
7066
) as dag:
7167
"""
72-
# schedule="0 0 * * *",
73-
# start_date=datetime(2021, 1, 1),
7468

7569
self._prep_commands(output_folder)
7670

@@ -81,9 +75,6 @@ def translate(self, output_folder: pathlib.Path, name: Optional[str] = None) ->
8175
bash_command='{self.task_commands[task.task_id]}',
8276
)
8377
"""
84-
# depends_on_past=False,
85-
# env={{"AIRFLOW_HOME": os.environ["AIRFLOW_HOME"]}},
86-
# retries=3,
8778

8879
for task in self.tasks.values():
8980
# Comma-separated list of the task's parents

0 commit comments

Comments
 (0)