FEAT:Enhance BlockingScheduler with configurable wait_seconds parameter

JK_Lu · JK_Lu · commit c8bd58597cea · 2025-02-20T22:39:56.000+08:00
diff --git a/src/apscheduler/schedulers/base.py b/src/apscheduler/schedulers/base.py
@@ -1255,7 +1255,7 @@ def _process_jobs(self):
         else:
             now = datetime.now(self.timezone)
             wait_seconds = min(
-                max((next_wakeup_time - now).total_seconds(), 0), TIMEOUT_MAX
+                max((next_wakeup_time - now).total_seconds(), 0), self.max_timeout
             )
             self._logger.debug(
                 "Next wakeup is due at %s (in %f seconds)",

Original file line number	Diff line number	Diff line change
`@@ -1255,7 +1255,7 @@ def _process_jobs(self):`
`1255`	`1255`	`else:`
`1256`	`1256`	`now = datetime.now(self.timezone)`
`1257`	`1257`	`wait_seconds = min(`
`1258`		`- max((next_wakeup_time - now).total_seconds(), 0), TIMEOUT_MAX`
	`1258`	`+ max((next_wakeup_time - now).total_seconds(), 0), self.max_timeout`
`1259`	`1259`	`)`
`1260`	`1260`	`self._logger.debug(`
`1261`	`1261`	`"Next wakeup is due at %s (in %f seconds)",`