Update scheduler.py to reflect migration for timeout function (#2763)

* Update scheduler.py to reflect migration for timeout function

* Update database.py

Author: cccs-mog

lib/cuckoo/core/database.py

@@ -2223,7 +2223,7 @@ def clean_timed_out_tasks(self, timeout: int):
             return
 
         # Calculate the cutoff time before which tasks are considered timed out.
-        timeout_threshold = datetime.now() - timedelta(seconds=timeout)
+        timeout_threshold = datetime.utcnow() - timedelta(seconds=timeout)
 
         # Build a single, efficient DELETE statement that filters in the database.
         delete_stmt = delete(Task).where(Task.status == TASK_PENDING).where(Task.added_on < timeout_threshold)

lib/cuckoo/core/scheduler.py

@@ -105,7 +105,7 @@ def do_main_loop_work(self, error_queue: queue.Queue) -> SchedulerCycleDelay:
             if self.next_timeout_time < time.time():
                 self.next_timeout_time = time.time() + self.cfg.cuckoo.get("task_timeout_scan_interval", 30)
                 with self.db.session.begin():
-                    self.db.check_tasks_timeout(self.cfg.cuckoo.get("task_pending_timeout", 0))
+                    self.db.clean_timed_out_tasks(self.cfg.cuckoo.get("task_pending_timeout", 0))
 
         analysis_manager: Optional[AnalysisManager] = None
         with self.db.session.begin():