From 8c0f54b0d50f52841e8bdf26d2039382855c8604 Mon Sep 17 00:00:00 2001 From: geekbing Date: Mon, 20 May 2024 17:01:27 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/apps/lunarlink/utils/task.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/backend/apps/lunarlink/utils/task.py b/backend/apps/lunarlink/utils/task.py index 2186bed..f49c4a8 100644 --- a/backend/apps/lunarlink/utils/task.py +++ b/backend/apps/lunarlink/utils/task.py @@ -101,7 +101,7 @@ def update_task(self, task_id): try: task_obj = celery_models.PeriodicTask.objects.get(id=task_id) except celery_models.PeriodicTask.DoesNotExist: - raise TaskNotFound + raise TaskNotFound(f"task {task_id} not found") crontab = celery_models.CrontabSchedule.objects.filter( **self.__crontab_time @@ -110,10 +110,10 @@ def update_task(self, task_id): crontab = celery_models.CrontabSchedule.objects.create( **self.__crontab_time ) - task_obj.save( - name=f"{self.__project}_{self.__name}", - crontab=crontab, - enabled=self.__switch, - args=json.dumps(self.__data, ensure_ascii=False), - kwargs=json.dumps(self.__email, ensure_ascii=False), - ) + + task_obj.name = f"{self.__project}_{self.__name}" + task_obj.crontab = crontab + task_obj.enabled = self.__switch + task_obj.args = json.dumps(self.__data, ensure_ascii=False) + task_obj.kwargs = json.dumps(self.__email, ensure_ascii=False) + task_obj.save()