From 9996b200f9ca5ae9a82963765ad04d2b549a4440 Mon Sep 17 00:00:00 2001
From: wangruidong <940853815@qq.com>
Date: Tue, 14 Nov 2023 14:33:03 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BD=9C=E4=B8=9A=E6=89=A7=E8=A1=8C?=
 =?UTF-8?q?=E5=8E=86=E5=8F=B2=E6=97=A5=E5=BF=97=E6=9C=AA=E6=8C=89=E9=85=8D?=
 =?UTF-8?q?=E7=BD=AE=E5=A4=A9=E6=95=B0=E6=B8=85=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/ops/tasks.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/apps/ops/tasks.py b/apps/ops/tasks.py
index d1da48dbe..5242d2812 100644
--- a/apps/ops/tasks.py
+++ b/apps/ops/tasks.py
@@ -140,5 +140,6 @@ def clean_job_execution_period():
     now = timezone.now()
     days = get_log_keep_day('JOB_EXECUTION_KEEP_DAYS')
     expired_day = now - datetime.timedelta(days=days)
-    del_res = JobExecution.objects.filter(date_created__lt=expired_day).delete()
-    logger.info(f"clean job_execution db record success! delete {days} days record, delete result: {del_res}")
+    with tmp_to_root_org():
+        del_res = JobExecution.objects.filter(date_created__lt=expired_day).delete()
+        logger.info(f"clean job_execution db record success! delete {days} days {del_res[0]} records")