You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
jobs = chord(group(
CELERY.signature('celery_task_1',
kwargs={<kwargs related to celery task 1>}).set(
queue="queue1") for file in files),
CELERY.signature('celery_task_2', immutable=True, kwargs={<kwargs related to task 2>}).set(
queue="queue2"))
result = jobs.apply_async()
This code is "intermittently" raising following error
raised: AttributeError("'DisabledBackend' object has no attribute '_restore_group'")
Traceback (most recent call last):
File "/usr/local/lib/python3.8/dist-packages/celery/backends/redis.py", line 488, in on_chord_part_return
header_result = GroupResult.restore(gid)
File "/usr/local/lib/python3.8/dist-packages/celery/result.py", line 960, in restore
return backend.restore_group(id)
File "/usr/local/lib/python3.8/dist-packages/celery/backends/base.py", line 656, in restore_group
meta = self.get_group_meta(group_id, cache=cache)
File "/usr/local/lib/python3.8/dist-packages/celery/backends/base.py", line 649, in get_group_meta
meta = self._restore_group(group_id)
AttributeError: 'DisabledBackend' object has no attribute '_restore_group'
Required Dependencies
Minimal Python Version: 3.8.0
Minimal Celery Version: 5.2.7
Minimal Kombu Version: 5.3.7
Minimal Broker Version: Using managed RabbitMq service
Minimal Result Backend Version: Using managed Redis service from AWS
Minimal OS and/or Kernel Version: Linux 5.10.213-201.855.amzn2.x86_64
Minimal Broker Client Version: amqp==5.2.0
Minimal Result Backend Client Version: redis==4.5.4
jobs = chord(group(
CELERY.signature('celery_task_1',
kwargs={<kwargs related to celery task 1>}).set(
queue="queue1") for file in files),
CELERY.signature('celery_task_2', immutable=True, kwargs={<kwargs related to task 2>}).set(
queue="queue2"))
result = jobs.apply_async()
It should not fail, and it should not raise any exception
As per my understanding this is happening when celery is trying to write the result in result backend.
Actual Behavior
When above mentioned code run, it fail randomly with the following error.
raised: AttributeError("'DisabledBackend' object has no attribute '_restore_group'")
Traceback (most recent call last):
File "/usr/local/lib/python3.8/dist-packages/celery/backends/redis.py", line 488, in on_chord_part_return
header_result = GroupResult.restore(gid)
File "/usr/local/lib/python3.8/dist-packages/celery/result.py", line 960, in restore
return backend.restore_group(id)
File "/usr/local/lib/python3.8/dist-packages/celery/backends/base.py", line 656, in restore_group
meta = self.get_group_meta(group_id, cache=cache)
File "/usr/local/lib/python3.8/dist-packages/celery/backends/base.py", line 649, in get_group_meta
meta = self._restore_group(group_id)
AttributeError: 'DisabledBackend' object has no attribute '_restore_group'
The text was updated successfully, but these errors were encountered:
@mahendrap1512 well the DisabledBackend error suggests that Celery doesn't have a result backend configured properly. Have you verified if the connection strings for the REDIS_URL is correct?
Also why is result backend is initialized twice? Its not necessary to do so if the broker URL and backend URL is in the config file
@mahendrap1512 well the DisabledBackend error suggests that Celery doesn't have a result backend configured properly. Have you verified if the connection strings for the REDIS_URL is correct?
Also why is result backend is initialized twice? Its not necessary to do so if the broker URL and backend URL is in the config file
Yeah, I checked the celery result backend is setup properly. Most of the time it works with no issues, it fails intermittently.
Also I checked the code result backend is only initialised once.
Checklist
main
branch of Celery.contribution guide
on reporting bugs.
for similar or identical bug reports.
for existing proposed fixes.
to find out if the bug was already fixed in the main branch.
in this issue (If there are none, check this box anyway).
Mandatory Debugging Information
celery -A proj report
in the issue.(if you are not able to do this, then at least specify the Celery
version affected).
main
branch of Celery.pip freeze
in the issue.to reproduce this bug.
Optional Debugging Information
and/or implementation.
result backend.
broker and/or result backend.
ETA/Countdown & rate limits disabled.
and/or upgrading Celery and its dependencies.
Related Issues and Possible Duplicates
Related Issues
Possible Duplicates
Environment & Settings
Celery version: 5.2.7 (dawn-chorus)
celery report
Output:Steps to Reproduce
This issue occur intermittently. So don't have the exact steps to replicate.
Setup Details
Celery app instantiate
Code (Which is failing error)
This code is "intermittently" raising following error
Required Dependencies
Python Packages
pip freeze
Output:Other Dependencies
N/A
Minimally Reproducible Test Case
Expected Behavior
When I run following code
It should not fail, and it should not raise any exception
As per my understanding this is happening when celery is trying to write the result in result backend.
Actual Behavior
When above mentioned code run, it fail randomly with the following error.
The text was updated successfully, but these errors were encountered: