mirror of
https://github.com/Tautulli/Tautulli.git
synced 2025-07-05 20:51:15 -07:00
54c9214b03
* Bump apscheduler from 3.8.0 to 3.9.1 Bumps [apscheduler](https://github.com/agronholm/apscheduler) from 3.8.0 to 3.9.1. - [Release notes](https://github.com/agronholm/apscheduler/releases) - [Changelog](https://github.com/agronholm/apscheduler/blob/3.9.1/docs/versionhistory.rst) - [Commits](https://github.com/agronholm/apscheduler/compare/3.8.0...3.9.1) --- updated-dependencies: - dependency-name: apscheduler dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * Update apscheduler==3.9.1 * Update pytz==2022.1 * Add pytz-deprecation-shim==0.1.0.post0 * Update tzdata==2022.1 * Update tzlocal==4.2 * Update requirements.txt Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: JonnyWong16 <9099342+JonnyWong16@users.noreply.github.com> [skip ci]
50 lines
1.6 KiB
Python
50 lines
1.6 KiB
Python
from __future__ import absolute_import
|
|
|
|
from apscheduler.schedulers.base import BaseScheduler
|
|
|
|
try:
|
|
from PyQt5.QtCore import QObject, QTimer
|
|
except (ImportError, RuntimeError): # pragma: nocover
|
|
try:
|
|
from PyQt4.QtCore import QObject, QTimer
|
|
except ImportError:
|
|
try:
|
|
from PySide6.QtCore import QObject, QTimer # noqa
|
|
except ImportError:
|
|
try:
|
|
from PySide2.QtCore import QObject, QTimer # noqa
|
|
except ImportError:
|
|
try:
|
|
from PySide.QtCore import QObject, QTimer # noqa
|
|
except ImportError:
|
|
raise ImportError('QtScheduler requires either PyQt5, PyQt4, PySide6, PySide2 '
|
|
'or PySide installed')
|
|
|
|
|
|
class QtScheduler(BaseScheduler):
|
|
"""A scheduler that runs in a Qt event loop."""
|
|
|
|
_timer = None
|
|
|
|
def shutdown(self, *args, **kwargs):
|
|
super(QtScheduler, self).shutdown(*args, **kwargs)
|
|
self._stop_timer()
|
|
|
|
def _start_timer(self, wait_seconds):
|
|
self._stop_timer()
|
|
if wait_seconds is not None:
|
|
wait_time = min(wait_seconds * 1000, 2147483647)
|
|
self._timer = QTimer.singleShot(wait_time, self._process_jobs)
|
|
|
|
def _stop_timer(self):
|
|
if self._timer:
|
|
if self._timer.isActive():
|
|
self._timer.stop()
|
|
del self._timer
|
|
|
|
def wakeup(self):
|
|
self._start_timer(0)
|
|
|
|
def _process_jobs(self):
|
|
wait_seconds = super(QtScheduler, self)._process_jobs()
|
|
self._start_timer(wait_seconds)
|