Sep 12 14:20:04 worker12 python3[25846]: [2018-09-12 14:20:04,287: ERROR/MainProcess] Task swh.vault.cooking_tasks.SWHCookingTask[a129a228-79b1-47e1-8c37-70e913c1f544] raised unexpected: ConnectionResetError(104, 'Connection reset by peer') Traceback (most recent call last): File "/usr/lib/python3/dist-packages/celery/app/trace.py", line 240, in trace_task R = retval = fun(*args, **kwargs) File "/usr/lib/python3/dist-packages/celery/app/trace.py", line 438, in __protected_call__ return self.run(*args, **kwargs) File "/usr/lib/python3/dist-packages/swh/scheduler/task.py", line 163, in run self.send_event('task-result', result=result) File "/usr/lib/python3/dist-packages/celery/app/task.py", line 802, in send_event with self.app.events.default_dispatcher(hostname=req.hostname) as d: File "/usr/lib/python3.5/contextlib.py", line 59, in __enter__ return next(self.gen) File "/usr/lib/python3/dist-packages/celery/events/__init__.py", line 406, in default_dispatcher prod.channel, buffer_while_offline) as d: File "/usr/lib/python3/dist-packages/celery/events/__init__.py", line 150, in __init__ self.enable() File "/usr/lib/python3/dist-packages/celery/events/__init__.py", line 169, in enable serializer=self.serializer) File "/usr/lib/python3/dist-packages/kombu/messaging.py", line 85, in __init__ self.revive(self._channel) File "/usr/lib/python3/dist-packages/kombu/messaging.py", line 222, in revive self.declare() File "/usr/lib/python3/dist-packages/kombu/messaging.py", line 105, in declare self.exchange.declare() File "/usr/lib/python3/dist-packages/kombu/entity.py", line 174, in declare nowait=nowait, passive=passive, File "/usr/lib/python3/dist-packages/amqp/channel.py", line 615, in exchange_declare self._send_method((40, 10), args) File "/usr/lib/python3/dist-packages/amqp/abstract_channel.py", line 56, in _send_method self.channel_id, method_sig, args, content, File "/usr/lib/python3/dist-packages/amqp/method_framing.py", line 221, in write_method write_frame(1, channel, payload) File "/usr/lib/python3/dist-packages/amqp/transport.py", line 182, in write_frame frame_type, channel, size, payload, 0xce, ConnectionResetError: [Errno 104] Connection reset by peer Sep 12 23:16:00 worker12 python3[25846]: [2018-09-12 23:16:00,362: INFO/MainProcess] Canceling queue celery Sep 12 23:16:00 worker12 python3[25846]: [2018-09-12 23:16:00,391: INFO/MainProcess] Canceling queue swh_vault_batch_cooking Sep 12 23:16:00 worker12 python3[25846]: [2018-09-12 23:16:00,406: INFO/MainProcess] Canceling queue swh_vault_cooking