We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3b2cf1b commit de989c6Copy full SHA for de989c6
scheduler/worker/scheduler.py
@@ -24,10 +24,10 @@ class SchedulerStatus(str, Enum):
24
25
26
def _reschedule_tasks() -> None:
27
- enabled_jobs = list(Task.objects.filter(enabled=True))
28
- for item in enabled_jobs:
29
- logger.debug(f"Rescheduling {str(item)}")
30
- item.save()
+ enabled_tasks = list(Task.objects.filter(enabled=True))
+ for task in enabled_tasks:
+ logger.debug(f"Rescheduling {str(task)}")
+ task.save(schedule_job=True, clean=False)
31
32
33
class WorkerScheduler:
0 commit comments