luojunhui 4 months ago
parent
commit
376e53d918
2 changed files with 10 additions and 10 deletions
  1. 9 9
      tasks/update_published_articles_minigram_detail.py
  2. 1 1
      update_mini_info_v2.py

+ 9 - 9
tasks/update_published_articles_minigram_detail.py

@@ -25,7 +25,7 @@ functions = Functions()
 
 TASK_NAME = "updateMinigramInfoDaily"
 ARTICLE_TABLE = "official_articles_v2"
-DETAIL_TABLE = "long_articles_detail_info"
+DETAIL_TABLE = "long_articles_detail_info_dev"
 EMPTY_LIST = []
 EMPTY_DICT = {}
 
@@ -121,7 +121,7 @@ class UpdatePublishedArticlesMinigramDetail(object):
         """
         select_sql = f"""
             SELECT first_uv, split0, split0_head, split0_recommend, split1, split1_head, split1_recommend, split2, split2_head, split2_recommend,
-            FROM changwen_data_rootsourceid
+            FROM changwen_data_rootsourceid_dev
             WHERE root_source_id = '{root_source_id}' AND dt = '{dt}';
         """
         result = self.long_articles_db_client.fetch(select_sql, cursor_type=DictCursor)
@@ -366,13 +366,13 @@ class UpdatePublishedArticlesMinigramDetail(object):
                 )
                 fail_count += 1
 
-        if fail_count:
-            bot(
-                title="{} fail because of lam db error".format(TASK_NAME),
-                detail={
-                    "fail_count": fail_count
-                }
-            )
+        # if fail_count:
+        #     bot(
+        #         title="{} fail because of lam db error".format(TASK_NAME),
+        #         detail={
+        #             "fail_count": fail_count
+        #         }
+        #     )
 
 
 

+ 1 - 1
update_mini_info_v2.py

@@ -25,7 +25,7 @@ def main():
         update_minigram_detail_task.update_published_articles_job(biz_date=args.run_date)
         update_minigram_detail_task.update_mini_program_detail_job(biz_date=args.run_date)
     else:
-        update_minigram_detail_task.update_published_articles_job()
+        # update_minigram_detail_task.update_published_articles_job()
         update_minigram_detail_task.update_mini_program_detail_job()