From 04692f644e745667ee72350105d6bd187372e502 Mon Sep 17 00:00:00 2001 From: Yam ZhengLim Date: Wed, 22 Feb 2023 00:50:26 +0800 Subject: [PATCH] Add print indecate --- main.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/main.py b/main.py index 1969e37..3b165fd 100644 --- a/main.py +++ b/main.py @@ -124,13 +124,17 @@ def crisp_load_to_cloudstorage(CRISP_CSV_TEMP_STORAGE_PATH): def main(): # Exchange + print("RUNNING MAIN_PY") #Make sure cron in the file directory general_function.change_to_current_directory() #Extract Load Exchange Data EXCHANGE_CSV_TEMP_STORAGE_PATH = "./exchange/extract/exchange_temp_extract_csv/" + print("STARTING EXCHANGE EXTRACT") exchange_extract(EXCHANGE_CSV_TEMP_STORAGE_PATH) + print("STARTING EXCHANGE LOAD") exchange_load_to_cloudstorage(EXCHANGE_CSV_TEMP_STORAGE_PATH) #Delete Temp CSV + print("DELETING EXCHANGE CSV") general_function.delete_csv_in_path(EXCHANGE_CSV_TEMP_STORAGE_PATH) # Shipping @@ -138,9 +142,12 @@ def main(): general_function.change_to_current_directory() #Extract Load SHIPPING Data SHIPPING_CSV_TEMP_STORAGE_PATH = "./shipping/extract/shipping_temp_extract_csv/" + print("STARTING SHIPPING EXTRACT") shipping_extract(SHIPPING_CSV_TEMP_STORAGE_PATH) + print("STARTING SHIPPING LOAD") shipping_load_to_cloudstorage(SHIPPING_CSV_TEMP_STORAGE_PATH) #Delete Temp CSV + print("DELETING SHIPPING CSV") general_function.delete_csv_in_path(SHIPPING_CSV_TEMP_STORAGE_PATH) # CRISP @@ -148,9 +155,12 @@ def main(): general_function.change_to_current_directory() #Extract Load Exchange Data CRISP_CSV_TEMP_STORAGE_PATH = "./crisp/extract/crisp_temp_extract_csv/" + print("STARTING CRISP EXTRACT") crisp_extract(CRISP_CSV_TEMP_STORAGE_PATH) + print("STARTING CRISP LOAD") crisp_load_to_cloudstorage(CRISP_CSV_TEMP_STORAGE_PATH) #Delete Temp CSV + print("DELETING CRISP CSV") general_function.delete_csv_in_path(CRISP_CSV_TEMP_STORAGE_PATH) if True: