From 890cfbd75ac0be6a61384def51c65eb0718cd130 Mon Sep 17 00:00:00 2001 From: "kyj@bowong.ai" Date: Thu, 17 Apr 2025 17:36:41 +0800 Subject: [PATCH] =?UTF-8?q?PERF=20=E5=AE=8C=E5=96=84=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E8=BE=93=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- AutoDL/autodl_scheduling/server.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/AutoDL/autodl_scheduling/server.py b/AutoDL/autodl_scheduling/server.py index a3da9bd..efcd698 100644 --- a/AutoDL/autodl_scheduling/server.py +++ b/AutoDL/autodl_scheduling/server.py @@ -87,10 +87,10 @@ class Server: # 更新实例池状态 instance.active = True instance.last_active_time = time.time() - loguru.logger.info("Task Submitted") + loguru.logger.info("Task[%s] Submitted" % uid) self.result_map.set(uid, {"status": "running", "msg": "Task Submitted, Waiting for result"}) else: - loguru.logger.error("Submit Task Failed") + loguru.logger.error("Submit Task[%s] Failed" % uid) self.result_map.set(uid, {"status":"fail", "msg":"Submit Task Failed"}) #查询结果放到结果缓存里 @@ -103,12 +103,12 @@ class Server: if result["status"] == "fail": #删除失败任务的实例 self.instance_pool.remove_instance(Instance(uuid=task["instance_id"])) - loguru.logger.info("Instance[%s] Removed Due to Task Failure" % task["instance_id"]) + loguru.logger.info("Instance[%s] Removed Due to Task[%s] Failure" % (task["instance_id"], uid)) else: #更新成功任务实例的状态 for instance in self.instance_pool.instances: if instance.uuid == task["instance_id"]: - loguru.logger.info("Instance[%s] Task Finished" % instance.uuid) + loguru.logger.info("Instance[%s] Task[%s] Finished" % (instance.uuid, uid)) instance.active = False instance.last_active_time = time.time() time.sleep(0.5)