swh_scheduler_celery_app = <Celery celery.tests at 0x7fd9dd768278> swh_scheduler_celery_includes = ['swh.scheduler.tests.tasks', 'swh.loader.mercurial.tasks', 'swh.loader.mercurial.tasks_from_disk', 'swh.loader.package.archive.tasks', 'swh.loader.package.cran.tasks', 'swh.loader.package.debian.tasks', ...] @pytest.fixture(scope="session") def swh_scheduler_celery_worker( swh_scheduler_celery_app, swh_scheduler_celery_includes, ): """Spawn a worker""" for module in swh_scheduler_celery_includes: swh_scheduler_celery_app.loader.import_task_module(module) > with worker.start_worker(swh_scheduler_celery_app, pool="solo") as w: .tox/py3/lib/python3.7/site-packages/swh/scheduler/pytest_plugin.py:103: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ /usr/lib/python3.7/contextlib.py:112: in __enter__ return next(self.gen) .tox/py3/lib/python3.7/site-packages/celery/contrib/testing/worker.py:82: in start_worker assert ping.delay().get(timeout=ping_task_timeout) == 'pong' .tox/py3/lib/python3.7/site-packages/celery/result.py:230: in get on_message=on_message, .tox/py3/lib/python3.7/site-packages/celery/backends/base.py:655: in wait_for_pending no_ack=no_ack, _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <celery.backends.cache.CacheBackend object at 0x7fd9d79dfda0> task_id = '7c8e9257-a371-4d69-849d-cdc06e37e207', timeout = 10.0, interval = 0.5 no_ack = True, on_interval = <promise@0x7fd9d7aa9768> def wait_for(self, task_id, timeout=None, interval=0.5, no_ack=True, on_interval=None): """Wait for task and return its result. If the task raises an exception, this exception will be re-raised by :func:`wait_for`. Raises: celery.exceptions.TimeoutError: If `timeout` is not :const:`None`, and the operation takes longer than `timeout` seconds. """ self._ensure_not_eager() time_elapsed = 0.0 while 1: meta = self.get_task_meta(task_id) if meta['status'] in states.READY_STATES: return meta if on_interval: on_interval() # avoid hammering the CPU checking status. time.sleep(interval) time_elapsed += interval if timeout and time_elapsed >= timeout: > raise TimeoutError('The operation timed out.') E celery.exceptions.TimeoutError: The operation timed out. .tox/py3/lib/python3.7/site-packages/celery/backends/base.py:687: TimeoutError