调整

tasks.py

@@ -849,7 +849,8 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config,
                         await kafka_service.send_message_async(k_message)
                         # await asyncio.sleep(random.uniform(1.5, 3))
                         # await asyncio.sleep(random.uniform(30, 60))
-                        await asyncio.sleep(random.uniform(270,300))
+                        delay=random.uniform(270,300)
+                        await asyncio.sleep(delay)
                     # 任务状态推送到kafka
                     task_status = await gewe_service.wx_add_contacts_from_chatroom_task_status_async(wxid, chatroom_id)
                     k_message=wx_add_contacts_from_chatroom_task_status_message(wxid, chatroom_id, task_status)