git-sync/profilarr
1
0
Fork 0
mirror of https://github.com/Dictionarry-Hub/profilarr.git synced 2026-01-30 06:10:56 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: enhance load_tasks_from_db method to remove old jobs before reloading tasks

Browse Source
This commit is contained in:
Sam Chau
2025-01-08 21:10:54 +10:30
parent 4d19ecac1e
commit d93b57975c
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
backend/app/task/tasks.py
View File

@@ -50,15 +50,23 @@ class TaskScheduler:
return cls._instance
def load_tasks_from_db(self):
"""
Reload tasks from the DB, removing all old jobs first
so we don't collide with existing job IDs.
"""
self.logger.debug(
"[TaskScheduler] remove_all_jobs to avoid duplicates")
self.scheduler.remove_all_jobs()
with get_db() as conn:
tasks = conn.execute('SELECT * FROM scheduled_tasks').fetchall()
for task_data in tasks:
task_class = self.get_task_class(task_data['type'])
task_rows = conn.execute(
'SELECT * FROM scheduled_tasks').fetchall()
for row in task_rows:
task_class = self.get_task_class(row['type'])
if task_class:
task = task_class(
id=task_data['id'],
name=task_data['name'],
interval_minutes=task_data['interval_minutes'])
task = task_class(id=row['id'],
name=row['name'],
interval_minutes=row['interval_minutes'])
self.schedule_task(task)
def schedule_task(self, task):