From c1fdd086ea47958c5a2d197e874c72eb793be3b6 Mon Sep 17 00:00:00 2001 From: hanshuaikang <1758504262@qq.com> Date: Wed, 11 Oct 2023 16:56:59 +0800 Subject: [PATCH] =?UTF-8?q?bugfix:=20=E5=AE=A1=E8=AE=A1=E9=A1=B5=E9=9D=A2?= =?UTF-8?q?=E8=BF=94=E5=9B=9E=E5=85=A8=E9=87=8F=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- gcloud/core/apis/drf/viewsets/taskflow.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/gcloud/core/apis/drf/viewsets/taskflow.py b/gcloud/core/apis/drf/viewsets/taskflow.py index 138a7c54b0..e467660632 100644 --- a/gcloud/core/apis/drf/viewsets/taskflow.py +++ b/gcloud/core/apis/drf/viewsets/taskflow.py @@ -275,9 +275,14 @@ class TaskFlowInstanceViewSet(GcloudReadOnlyViewSet, generics.CreateAPIView, gen def list(self, request, *args, **kwargs): queryset = self.filter_queryset(self.get_queryset()) - start_time = datetime.now() - timedelta(days=settings.TASK_LIST_STATUS_FILTER_DAYS) - queryset = queryset.filter(pipeline_instance__create_time__gte=start_time) task_instance_status = request.query_params.get("task_instance_status") + + user_type = request.query_params.get("user_type") + + # 对于非审计页面才需要增加查询时间限制 + if user_type != "auditor": + start_time = datetime.now() - timedelta(days=settings.TASK_LIST_STATUS_FILTER_DAYS) + queryset = queryset.filter(pipeline_instance__create_time__gte=start_time) if task_instance_status: # 状态查询的范围为最近TASK_LIST_STATUS_FILTER_DAYS天内，已经开始的v2引擎的任务 queryset = queryset.filter(