2024-06-13

异步定时任务

applications/deal/process_deal.py

@@ -37,7 +37,7 @@ class ProcessDeal(object):
         for content_id in content_ids:
             cil.append(content_id[0])
         content_ids_tuple = str(cil).replace("[", "(").replace("]", ")")
-        if len(content_ids_tuple) > 0:
+        if len(content_ids_tuple) > 3:
             select_sql = f"""
                 SELECT trace_id, content_id, gh_id, article_title, article_text, content_status, process_times
                 FROM {db_article} 
@@ -285,7 +285,6 @@ class ProcessDeal(object):
         :return:
         """
         task_list = await self.get_task()
-        print(task_list)
         task_dict = {}
         for task in task_list:
             key = task['content_id']