bothub-it / celery-worker-on-demand Goto Github PK

  File "/root/src/celery-worker-on-demand/celery_worker_on_demand/__init__.py", line 62, in queue_size,
AttributeError: 'Channel' object has no attribute '_size',
    return self.cwod.channel._size(queue.name),
    queue.size = self.queue_size(queue),
    self.run(),
Traceback (most recent call last):,
  File "/usr/local/lib/python3.6/threading.py", line 916, in _bootstrap_inner,
  File "/root/src/celery-worker-on-demand/celery_worker_on_demand/__init__.py", line 53, in run

Exception in thread Thread-2:,
Traceback (most recent call last):,
  File "/usr/local/lib/python3.6/threading.py", line 916, in _bootstrap_inner,
    self.run(),
  File "/root/src/celery-worker-on-demand/celery_worker_on_demand/__init__.py", line 124, in run,
    recv.capture(limit=None, timeout=None, wakeup=True),
  File "/usr/local/lib/python3.6/site-packages/celery/events/receiver.py", line 92, in capture,
    return list(self.consume(limit=limit, timeout=timeout, wakeup=wakeup)),
  File "/usr/local/lib/python3.6/site-packages/kombu/mixins.py", line 192, in consume,
    conn.drain_events(timeout=safety_interval),
  File "/usr/local/lib/python3.6/site-packages/kombu/connection.py", line 315, in drain_events,
    return self.transport.drain_events(self.connection, **kwargs),
  File "/usr/local/lib/python3.6/site-packages/kombu/transport/pyamqp.py", line 103, in drain_events,
    return connection.drain_events(**kwargs),
  File "/usr/local/lib/python3.6/site-packages/amqp/connection.py", line 491, in drain_events,
    while not self.blocking_read(timeout):,
  File "/usr/local/lib/python3.6/site-packages/amqp/connection.py", line 496, in blocking_read,
    frame = self.transport.read_frame(),
  File "/usr/local/lib/python3.6/site-packages/amqp/transport.py", line 243, in read_frame,
    frame_header = read(7, True),
  File "/usr/local/lib/python3.6/site-packages/amqp/transport.py", line 418, in _read,
    s = recv(n - len(rbuf)),
ConnectionResetError: [Errno 104] Connection reset by peer