Add Function Remove File

1_mgate.py

@@ -159,6 +159,13 @@ with DAG("APJ_1_mgate",
         op_kwargs={},
     )
 
+    remove_file_before = BashOperator(
+        task_id="remove_file",
+        bash_command=f"""
+            cd {Variable.get("LOCAL_PATH")}{DS_FOLDER}/{yesterday_lusa}/ && rm {yesterday_lusa}*
+        """
+    )
+
     history_start = PostgresOperator(
         sql=f"""INSERT INTO ds_conf."Datasource_history"
         (source, start_time, finish_time, status, env, date_of_data) VALUES