fix bug

jxxghp · Sep 24, 2023 · a7b51d9 · a7b51d9
1 parent 76f1de4
commit a7b51d9
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/app/scheduler.py b/app/scheduler.py
@@ -230,14 +230,15 @@ def list(self) -> List[schemas.ScheduleInfo]:
                 added.append(job.name)
             else:
                 continue
-            if not self._jobs.get(job.id):
+            job_id = job.id.split("|")[0]
+            if not self._jobs.get(job_id):
                 continue
             # 任务状态
-            status = "正在运行" if self._jobs[job.id].get("running") else "等待"
+            status = "正在运行" if self._jobs[job_id].get("running") else "等待"
             # 下次运行时间
             next_run = TimerUtils.time_difference(job.next_run_time)
             schedulers.append(schemas.ScheduleInfo(
-                id=job.id,
+                id=job_id,
                 name=job.name,
                 status=status,
                 next_run=next_run