修复任务id获取

scheduler/async_consumer.py

@@ -44,7 +44,7 @@ async def async_handle_topic(topic: str, stop_event: asyncio.Event):
 
         try:
             payload = json.loads(message.message_body)
-            task_id = payload["task_id"]
+            task_id = payload["id"]
             logger.info(f"[{topic}]接收到任务消息: {task_id}")
 
             aliyun_logger.logging(