-
Notifications
You must be signed in to change notification settings - Fork 93
Open
Description
Just upgraded to librabbitmq 1.5.2 and celery 3.1.12
I'm getting a failure during one of my tasks that involves a large chord.
Stacktrace (most recent call last):
File "celery/app/trace.py", line 240, in trace_task
R = retval = fun(*args, **kwargs)
File "newrelic/hooks/application_celery.py", line 66, in wrapper
return wrapped(*args, **kwargs)
File "celery/app/trace.py", line 437, in __protected_call__
return self.run(*args, **kwargs)
File "celery/app/builtins.py", line 75, in unlock_chord
if deps.ready():
File "celery/result.py", line 499, in ready
return all(result.ready() for result in self.results)
File "celery/result.py", line 499, in
return all(result.ready() for result in self.results)
File "celery/result.py", line 255, in ready
return self.state in self.backend.READY_STATES
File "celery/result.py", line 390, in state
return self._get_task_meta()['status']
File "celery/result.py", line 328, in _get_task_meta
meta = self.backend.get_task_meta(self.id)
File "celery/backends/amqp.py", line 173, in get_task_meta
accept=self.accept, no_ack=False,
File "kombu/entity.py", line 570, in get
message = self.channel.basic_get(queue=self.name, no_ack=no_ack)
File "librabbitmq/__init__.py", line 65, in basic_get
frame = self.connection._basic_get(self.channel_id, queue, no_ack)
Task celery.chord_unlock[a360ea41-91c0-4dec-b95f-c1baa3874ce4] raised unexpected: ConnectionError('Bad frame read',)
This seems like it might be related to #30
Metadata
Metadata
Assignees
Labels
No labels