Fix the task run method and data type (#228)

Author: wu-clan

backend/app/schemas/task.py

@@ -1,5 +1,7 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
+from datetime import datetime
+
 from backend.app.schemas.base import SchemaBase
 
 
@@ -12,4 +14,4 @@ class GetTask(SchemaBase):
     misfire_grace_time: str
     coalesce: str
     max_instances: str
-    next_run_time: str
+    next_run_time: datetime | None

backend/app/services/task_service.py

@@ -1,11 +1,14 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
+from datetime import datetime
+
+import pytz
 from asgiref.sync import sync_to_async
 
 from backend.app.common.exception import errors
 from backend.app.common.task import scheduler
+from backend.app.core.conf import settings
 from backend.app.schemas.task import GetTask
-from backend.app.utils.timezone import timezone
 
 
 class TaskService:
@@ -55,7 +58,8 @@ def get_task(pk: str):
 
     async def run(self, pk: str):
         task = await self.get_task(pk=pk)
-        scheduler.modify_job(job_id=pk, next_run_time=timezone.now())
+        # next_run_time 仅适用于 pytz 模块
+        scheduler.modify_job(job_id=pk, next_run_time=datetime.now(pytz.timezone(settings.DATETIME_TIMEZONE)))
         return task
 
     async def pause(self, pk: str):