FDSSUPPORT

1_t24_fdssupport.py

@@ -312,7 +312,7 @@ with DAG("APJ_FDS_T24",
 
     ds_nominatif = TriggerDagRunOperator(
        task_id=f'ds_nominatif',
-       trigger_dag_id="APJ_1_t24_interface_fdssupport",
+       trigger_dag_id="APJ_FDS_T24_Interface",
    )
 
 
@@ -342,4 +342,4 @@ with DAG("APJ_FDS_T24",
 #        postgres_conn_id=POSTGRES_CONN_ID,
 #    )
 
-    begin >> check_done_ext >> check_file_done  >> history_start >> file_sc_cp >> metadata_truncate >> metadata_sed >> metadata_list_extractor >> metadata_syntax_copy >> metadata_import >> metadata_refresh >> ds_create_table  >> ds_list_extractor >> ds_syntax_copy >> ds_csv_to_table  >> ds_create_metadata_file >> ds_create_metadata_file_sys >> set_access_schemma >> set_access_all_table  >> ds_nominatif >> ds_remove_bnk >> ds_ext_done
+    begin >> check_done_ext >> check_file_done  >> file_sc_cp >> metadata_truncate >> metadata_sed >> metadata_list_extractor >> metadata_syntax_copy >> metadata_import >> metadata_refresh >> ds_create_table  >> ds_list_extractor >> ds_syntax_copy >> ds_csv_to_table  >> ds_create_metadata_file >> ds_create_metadata_file_sys >> set_access_schemma >> set_access_all_table  >> ds_nominatif >> ds_remove_bnk >> ds_ext_done

1_t24_interface_fdssupport.py

@@ -298,4 +298,4 @@ with DAG("APJ_FDS_T24_Interface",
     # )
 
 
-    begin >> ds_list_extractor >> csv_clean_syntax >> clean_csv  >> pg_ddl_syntax >> pg_create_table >> ds_push_syntax >> sql_clean_syntax >> ds_csv_to_table >> ds_clean_data  >> stop_task  >> set_access_schemma >> set_access_all_table >> set_access_schemma_his >> set_access_all_table_his >> zip_today >> delete_before >> history_finish
+    begin >> ds_list_extractor >> csv_clean_syntax >> clean_csv  >> pg_ddl_syntax >> pg_create_table >> ds_push_syntax >> sql_clean_syntax >> ds_csv_to_table >> ds_clean_data  >> stop_task  >> set_access_schemma >> set_access_all_table >> set_access_schemma_his >> set_access_all_table_his >> zip_today