Skip to content

GitLab

A
Airflow
Commit ebb99f22 authored by Timothy Ardha's avatar Timothy Ardha
Browse files
Options

Update ZIP Function

parent ce6bbd15
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 2 deletions
1_t24_interface.py
View file @ ebb99f22
...@@ -290,9 +290,10 @@ with DAG("APJ_1_t24_interface", ...@@ -290,9 +290,10 @@ with DAG("APJ_1_t24_interface",
zip_today = BashOperator( zip_today = BashOperator(
task_id="zip_today", task_id="zip_today",
# bash_command=f"""zip -r /opt/airflow/dags/DFE/t24/{yesterday_nodash}.zip /opt/airflow/dags/DFE/t24/{yesterday_nodash};""",
bash_command=f""" bash_command=f"""
zip -r /opt/airflow/dags/DFE/t24/{yesterday_nodash}.zip /opt/airflow/dags/DFE/t24/{yesterday_nodash}; cd {Variable.get("LOCAL_PATH")}t24/ && zip -r {yesterday_nodash}.zip {yesterday_nodash};
""", """
) )
delete_before = BashOperator( delete_before = BashOperator(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment