Commit d36ed915 authored by Timothy Ardha's avatar Timothy Ardha

Update "delete_before" Task

parent e43e6e63
......@@ -269,7 +269,7 @@ with DAG("APJ_1_mgate",
delete_before = BashOperator(
task_id="delete_before",
bash_command=f"""
rm -r /opt/airflow/dags/DFE/{DS_FOLDER}/{yesterday_lusa};
rm -rf /opt/airflow/dags/DFE/{DS_FOLDER}/{yesterday_lusa};
""",
)
......
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