From 4a52a71956a8d46fcb7294ac71734504bb09bcc2 Mon Sep 17 00:00:00 2001 From: S. Solomon Darnell Date: Fri, 28 Mar 2025 21:52:21 -0500 Subject: two version of R2R are here --- .../site-packages/apscheduler/executors/gevent.py | 29 ++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 .venv/lib/python3.12/site-packages/apscheduler/executors/gevent.py (limited to '.venv/lib/python3.12/site-packages/apscheduler/executors/gevent.py') diff --git a/.venv/lib/python3.12/site-packages/apscheduler/executors/gevent.py b/.venv/lib/python3.12/site-packages/apscheduler/executors/gevent.py new file mode 100644 index 00000000..385be40c --- /dev/null +++ b/.venv/lib/python3.12/site-packages/apscheduler/executors/gevent.py @@ -0,0 +1,29 @@ +import sys + +from apscheduler.executors.base import BaseExecutor, run_job + +try: + import gevent +except ImportError as exc: # pragma: nocover + raise ImportError("GeventExecutor requires gevent installed") from exc + + +class GeventExecutor(BaseExecutor): + """ + Runs jobs as greenlets. + + Plugin alias: ``gevent`` + """ + + def _do_submit_job(self, job, run_times): + def callback(greenlet): + try: + events = greenlet.get() + except BaseException: + self._run_job_error(job.id, *sys.exc_info()[1:]) + else: + self._run_job_success(job.id, events) + + gevent.spawn( + run_job, job, job._jobstore_alias, run_times, self._logger.name + ).link(callback) -- cgit v1.2.3