From 47ceaf967c64c9a651e9c2650f4fb3a3e8787db7 Mon Sep 17 00:00:00 2001
From: wangruidong <940853815@qq.com>
Date: Thu, 28 Mar 2024 11:00:18 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E6=9F=A5=E7=9C=8B=E4=BD=9C=E4=B8=9A?=
 =?UTF-8?q?=E5=91=BD=E4=BB=A4=E4=BB=BB=E5=8A=A1=E6=89=A7=E8=A1=8C=E7=BB=93?=
 =?UTF-8?q?=E6=9E=9C=E6=B7=BB=E5=8A=A0=E7=94=A8=E6=88=B7=E9=9A=94=E7=A6=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/ops/api/celery.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/apps/ops/api/celery.py b/apps/ops/api/celery.py
index 43b63ce5b..ae4e9d8b6 100644
--- a/apps/ops/api/celery.py
+++ b/apps/ops/api/celery.py
@@ -248,6 +248,8 @@ class CeleryTaskExecutionViewSet(CommonApiMixin, viewsets.ModelViewSet):
         if task_id:
             task = get_object_or_404(CeleryTask, id=task_id)
             self.queryset = self.queryset.filter(name=task.name)
+        if not self.request.user.is_superuser:
+            self.queryset = self.queryset.filter(creator=self.request.user)
         return self.queryset
 
     def create(self, request, *args, **kwargs):