search

ebu / OSCIED

Open Source Cloud Infrastructure for Encoding and Distribution
Other
16 stars 2 forks source link

Workers : celery worker start error (if orchestra not yet ready), must retry #131

Open davidfischer-ch opened 10 years ago

davidfischer-ch commented 10 years ago

http://stackoverflow.com/questions/11165422/typeerror-occurring-while-using-celery-2-6-0rc5

return getattr(self._sock,name)(*args)
error: [Errno 104] Connection reset by peer
[2013-12-11 12:49:07,400: ERROR/MainProcess] consumer: Cannot connect to amqp://node@ip-172-31-16-96.eu-west-1.compute.internal:5672/celery: [Errno 111] Connection refused.
Trying again in 2.00 seconds...

[2013-12-11 12:49:09,411: ERROR/MainProcess] consumer: Cannot connect to amqp://node@ip-172-31-16-96.eu-west-1.compute.internal:5672/celery: [Errno 111] Connection refused.
Trying again in 4.00 seconds...

[2013-12-11 12:49:13,425: ERROR/MainProcess] consumer: Cannot connect to amqp://node@ip-172-31-16-96.eu-west-1.compute.internal:5672/celery: [Errno 111] Connection refused.
Trying again in 6.00 seconds...

[2013-12-11 12:49:19,441: ERROR/MainProcess] consumer: Cannot connect to amqp://node@ip-172-31-16-96.eu-west-1.compute.internal:5672/celery: [Errno 111] Connection refused.
Trying again in 8.00 seconds...

[2013-12-11 12:49:27,461: ERROR/MainProcess] Unrecoverable error: ValueError('I/O operation on closed epoll fd',)
Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/celery/worker/__init__.py", line 212, in start
    self.blueprint.start(self)
  File "/usr/local/lib/python2.7/dist-packages/celery/bootsteps.py", line 123, in start
    step.start(parent)
  File "/usr/local/lib/python2.7/dist-packages/celery/bootsteps.py", line 373, in start
    return self.obj.start()
  File "/usr/local/lib/python2.7/dist-packages/celery/worker/consumer.py", line 270, in start
    blueprint.start(self)
  File "/usr/local/lib/python2.7/dist-packages/celery/bootsteps.py", line 123, in start
    step.start(parent)
  File "/usr/local/lib/python2.7/dist-packages/celery/worker/consumer.py", line 467, in start
    c.connection = c.connect()
  File "/usr/local/lib/python2.7/dist-packages/celery/worker/consumer.py", line 369, in connect
    conn.transport.register_with_event_loop(conn.connection, self.hub)
  File "/usr/local/lib/python2.7/dist-packages/kombu/transport/pyamqp.py", line 124, in register_with_event_loop
    loop.add_reader(connection.sock, self.on_readable, connection, loop)
  File "/usr/local/lib/python2.7/dist-packages/kombu/async/hub.py", line 214, in add_reader
    return self.add(fds, callback, READ | ERR, args)
  File "/usr/local/lib/python2.7/dist-packages/kombu/async/hub.py", line 165, in add
    self.poller.register(fd, flags)
  File "/usr/local/lib/python2.7/dist-packages/kombu/utils/eventio.py", line 78, in register
    self._epoll.register(fd, events)
ValueError: I/O operation on closed epoll fd