Fix the celery task scheduler query (#719)

Author: wu-clan

backend/app/task/utils/schedulers.py

@@ -176,6 +176,7 @@ async def to_model_schedule(name: str, task: str, schedule: schedules.schedule |
             if isinstance(schedule, schedules.schedule):
                 every = max(schedule.run_every.total_seconds(), 0)
                 spec = {
+                    'name': name,
                     'type': TaskSchedulerType.INTERVAL.value,
                     'interval_every': every,
                     'interval_period': PeriodType.SECONDS.value,
@@ -184,10 +185,10 @@ async def to_model_schedule(name: str, task: str, schedule: schedules.schedule |
                 query = await db.execute(stmt)
                 obj = query.scalars().first()
                 if not obj:
-                    obj = TaskScheduler(**CreateTaskSchedulerParam(name=name, task=task, **spec).model_dump())
-                return obj
+                    obj = TaskScheduler(**CreateTaskSchedulerParam(task=task, **spec).model_dump())
             elif isinstance(schedule, schedules.crontab):
                 spec = {
+                    'name': name,
                     'type': TaskSchedulerType.CRONTAB.value,
                     'crontab_minute': schedule._orig_minute
                     if crontab_verify('m', schedule._orig_minute, False)
@@ -207,17 +208,12 @@ async def to_model_schedule(name: str, task: str, schedule: schedules.schedule |
                 query = await db.execute(stmt)
                 obj = query.scalars().first()
                 if not obj:
-                    obj = TaskScheduler(
-                        **CreateTaskSchedulerParam(
-                            name=name,
-                            task=task,
-                            **spec,
-                        ).model_dump()
-                    )
-                return obj
+                    obj = TaskScheduler(**CreateTaskSchedulerParam(task=task, **spec).model_dump())
             else:
                 raise errors.NotFoundError(msg=f'暂不支持的计划类型：{schedule}')
 
+            return obj
+
     @classmethod
     async def _unpack_fields(
         cls,