no message

Pyspark_job/sqoop_export/export_dwt_asin_sync.py

@@ -25,12 +25,16 @@ def export_data(site_name, date_type, date_info):
     cols_list = ['asin', 'asin_is_variation', 'volume', 'weight_str', 'date_info']
 
     import_table = f'{site_name}_all_syn_st_{date_type}_{date_info.replace("-", "_")}'
-    if date_type == 'day':
+    if date_type in ['day', 'week']:
         sql_truncate = f"truncate {import_table};"
         print(f"sql_truncate: {sql_truncate}")
         engine.execute(sql_truncate)
 
     hive_table = 'dwt_asin_sync'
+    if date_type == 'week':
+        cols_list = ['asin', 'date_info']
+        hive_table = 'ods_keepa_finder_asin'
+
     print(f"import_table: {import_table}, hive_table: {hive_table}")
     print(f"partitions: {partitions}")