From 2c4e579c1dd4a486acd59a5bc2d169e31f7585fc Mon Sep 17 00:00:00 2001 From: zxstty Date: Mon, 10 Nov 2025 18:43:25 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=9F=A5=E8=AF=A2=E6=88=91?= =?UTF-8?q?=E5=88=9B=E5=BB=BA=E7=9A=84=E5=9B=A2=E9=98=9F=E7=9A=84=E6=8A=A5?= =?UTF-8?q?=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- data_chain/apps/service/task_queue_service.py | 3 +-- data_chain/apps/service/team_service.py | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/data_chain/apps/service/task_queue_service.py b/data_chain/apps/service/task_queue_service.py index 58fde2f7..626a542f 100644 --- a/data_chain/apps/service/task_queue_service.py +++ b/data_chain/apps/service/task_queue_service.py @@ -33,7 +33,7 @@ class TaskQueueService: for task_id in pending_task_ids_not_in_db: task_entities_need_add.append(TaskQueueEntity( id=task_id, status=TaskStatus.PENDING.value)) - + st = time.time() running_task_entities = await TaskManager.list_task_by_task_status(TaskStatus.RUNNING.value) en = time.time() @@ -67,7 +67,6 @@ class TaskQueueService: await TaskQueueManager.delete_tasks_by_ids( task_need_delete_ids[i:i+batch_size]) en = time.time() - logging.info(f"[TaskQueueService] 删除任务耗时 {en-st} 秒") if len(task_entities_need_add) > 0: st = time.time() for i in range(0, len(task_entities_need_add), batch_size): diff --git a/data_chain/apps/service/team_service.py b/data_chain/apps/service/team_service.py index da1fc4c8..9718dd31 100644 --- a/data_chain/apps/service/team_service.py +++ b/data_chain/apps/service/team_service.py @@ -71,7 +71,7 @@ class TeamService: async def list_teams(user_sub: str, req: ListTeamRequest) -> ListTeamMsg: """列出团队""" if req.team_type == TeamType.MYCREATED: - total, team_entities = await TeamManager.list_team_mycreated_user_sub(user_sub, req) + total, team_entities = await TeamManager.list_team_mycreated_by_user_sub(user_sub, req) elif req.team_type == TeamType.MYJOINED: total, team_entities = await TeamManager.list_team_myjoined_by_user_sub(user_sub, req) elif req.team_type == TeamType.PUBLIC: -- Gitee