Commit e43e6e63 authored by Timothy Ardha's avatar Timothy Ardha

fix

parent 43a89a78
...@@ -160,7 +160,7 @@ with DAG("APJ_1_mgate", ...@@ -160,7 +160,7 @@ with DAG("APJ_1_mgate",
) )
remove_file_before = BashOperator( remove_file_before = BashOperator(
task_id="remove_file", task_id="remove_file_before",
bash_command=f""" bash_command=f"""
cd {Variable.get("LOCAL_PATH")}{DS_FOLDER}/{yesterday_lusa}/ && rm {yesterday_lusa}* cd {Variable.get("LOCAL_PATH")}{DS_FOLDER}/{yesterday_lusa}/ && rm {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