FM / executors

/opt/imh-python/lib/python3.9/site-packages/apscheduler/executors/

/opt/imh-python/lib/python3.9/site-packages/apscheduler/executors

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
asyncio.py	1768	0644	edit dl rm
base.py	7116	0644	edit dl rm
debug.py	573	0644	edit dl rm
gevent.py	761	0644	edit dl rm
pool.py	2683	0644	edit dl rm
tornado.py	1581	0644	edit dl rm
twisted.py	726	0644	edit dl rm
__init__.py	0	0644	edit dl rm

Edit: /opt/imh-python/lib/python3.9/site-packages/apscheduler/executors/tornado.py (1581B)

import sys
from concurrent.futures import ThreadPoolExecutor

from tornado.gen import convert_yielded

from apscheduler.executors.base import BaseExecutor, run_coroutine_job, run_job
from apscheduler.util import iscoroutinefunction_partial

class TornadoExecutor(BaseExecutor):
    """
    Runs jobs either in a thread pool or directly on the I/O loop.

If the job function is a native coroutine function, it is scheduled to be run directly in the
    I/O loop as soon as possible. All other functions are run in a thread pool.

Plugin alias: ``tornado``

:param int max_workers: maximum number of worker threads in the thread pool
    """

def __init__(self, max_workers=10):
        super().__init__()
        self.executor = ThreadPoolExecutor(max_workers)

def start(self, scheduler, alias):
        super().start(scheduler, alias)
        self._ioloop = scheduler._ioloop

def _do_submit_job(self, job, run_times):
        def callback(f):
            try:
                events = f.result()
            except BaseException:
                self._run_job_error(job.id, *sys.exc_info()[1:])
            else:
                self._run_job_success(job.id, events)

if iscoroutinefunction_partial(job.func):
            f = run_coroutine_job(
                job, job._jobstore_alias, run_times, self._logger.name
            )
        else:
            f = self.executor.submit(
                run_job, job, job._jobstore_alias, run_times, self._logger.name
            )

f = convert_yielded(f)
        f.add_done_callback(callback)

import sys from concurrent.futures import ThreadPoolExecutor from tornado.gen import convert_yielded from apscheduler.executors.base import BaseExecutor, run_coroutine_job, run_job from apscheduler.util import iscoroutinefunction_partial class TornadoExecutor(BaseExecutor): """ Runs jobs either in a thread pool or directly on the I/O loop. If the job function is a native coroutine function, it is scheduled to be run directly in the I/O loop as soon as possible. All other functions are run in a thread pool. Plugin alias: ``tornado`` :param int max_workers: maximum number of worker threads in the thread pool """ def __init__(self, max_workers=10): super().__init__() self.executor = ThreadPoolExecutor(max_workers) def start(self, scheduler, alias): super().start(scheduler, alias) self._ioloop = scheduler._ioloop def _do_submit_job(self, job, run_times): def callback(f): try: events = f.result() except BaseException: self._run_job_error(job.id, *sys.exc_info()[1:]) else: self._run_job_success(job.id, events) if iscoroutinefunction_partial(job.func): f = run_coroutine_job( job, job._jobstore_alias, run_times, self._logger.name ) else: f = self.executor.submit( run_job, job, job._jobstore_alias, run_times, self._logger.name ) f = convert_yielded(f) f.add_done_callback(callback)