Skip to content

Celery - Queue object has no attribute 'all_tasks_done' #471

@oji

Description

@oji

Hi all,

I'm integrating Sentry on a project in python that uses Celery. I'm getting this error when shutting down the worker:

Error in atexit._run_exitfuncs:
Traceback (most recent call last):
  File "/Users/jibanez/API/.conda/envs/cimrender/lib/python3.6/site-packages/sentry_sdk/worker.py", line 84, in flush
    self._wait_flush(timeout, callback)
  File "/Users/jibanez/API/.conda/envs/cimrender/lib/python3.6/site-packages/sentry_sdk/worker.py", line 90, in _wait_flush
    if not self._timed_queue_join(initial_timeout):
  File "/Users/jibanez/API/.conda/envs/cimrender/lib/python3.6/site-packages/sentry_sdk/worker.py", line 48, in _timed_queue_join
    queue.all_tasks_done.acquire()  # type: ignore
AttributeError: 'Queue' object has no attribute 'all_tasks_done'

I'm using:

  • Python 3.6
  • Celery 4.3.0
  • OSX Mojave

Any thoughts?

Metadata

Metadata

Assignees

No one assigned

    Labels

    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions