From 263177c7171b2448d503c8788dd4eac0e3ab5354 Mon Sep 17 00:00:00 2001 From: Yam ZhengLim Date: Mon, 19 Dec 2022 15:26:50 +0800 Subject: [PATCH] Pause for CRISP --- main.py | 52 ++++++++++++++++++++++++++-------------------------- 1 file changed, 26 insertions(+), 26 deletions(-) diff --git a/main.py b/main.py index 15049f4..258e03b 100644 --- a/main.py +++ b/main.py @@ -123,36 +123,36 @@ def crisp_load_to_cloudstorage(CRISP_CSV_TEMP_STORAGE_PATH): def main(): - # #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/" - # exchange_extract(EXCHANGE_CSV_TEMP_STORAGE_PATH) - # exchange_load_to_cloudstorage(EXCHANGE_CSV_TEMP_STORAGE_PATH) - - # #Delete Temp CSV - # general_function.delete_csv_in_path(EXCHANGE_CSV_TEMP_STORAGE_PATH) - - # #Make sure cron in the file directory - # general_function.change_to_current_directory() - - # #Extract Load SHIPPING Data - # SHIPPING_CSV_TEMP_STORAGE_PATH = "./shipping/extract/shipping_temp_extract_csv/" - # shipping_extract(SHIPPING_CSV_TEMP_STORAGE_PATH) - # shipping_load_to_cloudstorage(SHIPPING_CSV_TEMP_STORAGE_PATH) - - # #Delete Temp CSV - # general_function.delete_csv_in_path(SHIPPING_CSV_TEMP_STORAGE_PATH) - - #Make sure cron in the file directory general_function.change_to_current_directory() #Extract Load Exchange Data - CRISP_CSV_TEMP_STORAGE_PATH = "./crisp/extract/crisp_temp_extract_csv/" - crisp_extract(CRISP_CSV_TEMP_STORAGE_PATH) - crisp_load_to_cloudstorage(CRISP_CSV_TEMP_STORAGE_PATH) + EXCHANGE_CSV_TEMP_STORAGE_PATH = "./exchange/extract/exchange_temp_extract_csv/" + exchange_extract(EXCHANGE_CSV_TEMP_STORAGE_PATH) + exchange_load_to_cloudstorage(EXCHANGE_CSV_TEMP_STORAGE_PATH) + + #Delete Temp CSV + general_function.delete_csv_in_path(EXCHANGE_CSV_TEMP_STORAGE_PATH) + + #Make sure cron in the file directory + general_function.change_to_current_directory() + + #Extract Load SHIPPING Data + SHIPPING_CSV_TEMP_STORAGE_PATH = "./shipping/extract/shipping_temp_extract_csv/" + shipping_extract(SHIPPING_CSV_TEMP_STORAGE_PATH) + shipping_load_to_cloudstorage(SHIPPING_CSV_TEMP_STORAGE_PATH) + + #Delete Temp CSV + general_function.delete_csv_in_path(SHIPPING_CSV_TEMP_STORAGE_PATH) + + + # #Make sure cron in the file directory + # general_function.change_to_current_directory() + + # #Extract Load Exchange Data + # CRISP_CSV_TEMP_STORAGE_PATH = "./crisp/extract/crisp_temp_extract_csv/" + # crisp_extract(CRISP_CSV_TEMP_STORAGE_PATH) + # crisp_load_to_cloudstorage(CRISP_CSV_TEMP_STORAGE_PATH) # #Delete Temp CSV # general_function.delete_csv_in_path(CRISP_CSV_TEMP_STORAGE_PATH)