INNER CODE UNIT · Python

_run

MichielMe/fastscheduler · src/fastscheduler/main.py:420

    def _run(self):
        """Main scheduler loop - runs in background thread."""
        if not self.quiet:
            logger.info("Scheduler main loop started")

        while self.running:
            try:
                now = time.time()
                jobs_to_run = []

                with self.lock:
                    while self.jobs and self.jobs[0].next_run <= now:
                        job = heapq.heappop(self.jobs)

                        if job.paused:
                            job.next_run = time.time() + 1.0
                            heapq.heappush(self.jobs, job)
                            continue

View source record →