diff --git a/data_chain/apps/service/task_queue_service.py b/data_chain/apps/service/task_queue_service.py index 58fde2f7754814e5f7d709ce20403db3cdec4270..626a542f4a9ec2dab000fe0e94c55769a6705440 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 da1fc4c8d80d4f3636a069e408dcb6f2ec5e5ac1..9718dd3167d919a05fc1e24e230452b2eb4625f1 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: