no message

Pyspark_job/sqoop_export/ods_st_key.py

@@ -10,10 +10,10 @@ from utils.db_util import DBUtil
 if __name__ == '__main__':
     site_name = CommonUtil.get_sys_arg(1, None)
 
-    CommonUtil.judge_is_work_hours(
-        site_name=site_name,
-        principal='chenyuanjie', priority=1, export_tools_type=1, belonging_to_process='更新搜索词key'
-    )
+    # CommonUtil.judge_is_work_hours(
+    #     site_name=site_name,
+    #     principal='chenyuanjie', priority=1, export_tools_type=1, belonging_to_process='更新搜索词key'
+    # )
 
     db_type = 'postgresql_cluster'
     engine = DBUtil.get_db_engine(db_type, site_name)

Pyspark_job/sqoop_import/ods_keepa_finder_asin.py

@@ -34,7 +34,7 @@ partition_dict = {
 
 if date_type == 'week':
     # db_type = 'doris'
-    sql_query = f"select null as id, null as request_id, asin, update_time as tracking_since from keepa_finder_asin where 1=1 " \
+    sql_query = f"select null as id, null as request_id, asin, update_time as tracking_since from keepa_finder_asin where 1=1 and date_info='{date_info}'" \
             f"and \$CONDITIONS"
     engine.sqoop_raw_import(
         query=sql_query,