Name	Size	Mode	Actions
__pycache__/	-	0755	rm
asynpool.py	51466	0644	editdlrm
base.py	4706	0644	editdlrm
eventlet.py	5126	0644	editdlrm
gevent.py	3387	0644	editdlrm
prefork.py	5850	0644	editdlrm
solo.py	754	0644	editdlrm
thread.py	1807	0644	editdlrm
__init__.py	1457	0644	editdlrm

"""Single-threaded execution pool.""" import os from celery import signals from .base import BasePool, apply_target __all__ = ('TaskPool',) class TaskPool(BasePool): """Solo task pool (blocking, inline, fast).""" body_can_be_buffer = True def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self.on_apply = apply_target self.limit = 1 signals.worker_process_init.send(sender=None) def _get_info(self): info = super()._get_info() info.update({ 'max-concurrency': 1, 'processes': [os.getpid()], 'max-tasks-per-child': None, 'put-guarded-by-semaphore': True, 'timeouts': (), }) return info