2024-06-13

异步定时任务

applications/deal/process_deal.py

@@ -269,15 +269,15 @@ class ProcessDeal(object):
         :return:
         """
         task_list = await self.get_task()
-        task_dict = {}
-        for task in task_list:
-            key = task['content_id']
-            task_dict[key] = task
-        process_list = []
-        for item in task_dict:
-            process_list.append(task_dict[item])
-        if process_list:
-            tasks = [self.process_task(params) for params in process_list]
+        # task_dict = {}
+        # for task in task_list:
+        #     key = task['content_id']
+        #     task_dict[key] = task
+        # process_list = []
+        # for item in task_dict:
+        #     process_list.append(task_dict[item])
+        if task_list:
+            tasks = [self.process_task(params) for params in task_list]
             await asyncio.gather(*tasks)
         else:
             logging(