bowong
/
modalDeploy
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

PERF 完善日志输出

This commit is contained in:
kyj@bowong.ai 2025-04-17 17:36:41 +08:00
parent 06182e30d5
commit 890cfbd75a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
AutoDL/autodl_scheduling/server.py
View File

@ -87,10 +87,10 @@ class Server:
# 更新实例池状态 # 更新实例池状态
instance.active = True instance.active = True
instance.last_active_time = time.time() 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"}) self.result_map.set(uid, {"status": "running", "msg": "Task Submitted, Waiting for result"})
else: 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"}) self.result_map.set(uid, {"status":"fail", "msg":"Submit Task Failed"})
#查询结果放到结果缓存里 #查询结果放到结果缓存里
@ -103,12 +103,12 @@ class Server:
if result["status"] == "fail": if result["status"] == "fail":
#删除失败任务的实例 #删除失败任务的实例
self.instance_pool.remove_instance(Instance(uuid=task["instance_id"])) 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: else:
#更新成功任务实例的状态 #更新成功任务实例的状态
for instance in self.instance_pool.instances: for instance in self.instance_pool.instances:
if instance.uuid == task["instance_id"]: 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.active = False
instance.last_active_time = time.time() instance.last_active_time = time.time()
time.sleep(0.5) time.sleep(0.5)