Page MenuHomeSoftware Heritage
Paste P112

[invalid] connection error when producing message for orchestrator - ardumont not in swhworker group!
ActivePublic
Actions

Authored by ardumont on Oct 10 2016, 4:07 PM.
ardumont@worker01:~% pigz -dc /srv/storage/space/lists/contents-sha1-to-azure.txt.gz | head | SWH_WORKER_INSTANCE=swh_indexer_orchestrator python3 -m swh.indexer.producer --batch 100 --limit 1000
10 sent - [b'=\x83=\x02\x14=\x1c\xad\xb8UjL\x91\xcc\x15C$B\xdel', ...]
Traceback (most recent call last):
File "/usr/lib/python3/dist-packages/kombu/utils/__init__.py", line 420, in __call__
return self.__value__
AttributeError: 'ChannelPromise' object has no attribute '__value__'
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 436, in _ensured
return fun(*args, **kwargs)
File "/usr/lib/python3/dist-packages/kombu/messaging.py", line 173, in _publish
channel = self.channel
File "/usr/lib/python3/dist-packages/kombu/messaging.py", line 190, in _get_channel
channel = self._channel = channel()
File "/usr/lib/python3/dist-packages/kombu/utils/__init__.py", line 422, in __call__
value = self.__value__ = self.__contract__()
File "/usr/lib/python3/dist-packages/kombu/messaging.py", line 205, in <lambda>
channel = ChannelPromise(lambda: connection.default_channel)
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 756, in default_channel
self.connection
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 741, in connection
self._connection = self._establish_connection()
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 696, in _establish_connection
conn = self.transport.establish_connection()
File "/usr/lib/python3/dist-packages/kombu/transport/pyamqp.py", line 112, in establish_connection
conn = self.Connection(**opts)
File "/usr/lib/python3/dist-packages/amqp/connection.py", line 165, in __init__
self.transport = create_transport(host, connect_timeout, ssl)
File "/usr/lib/python3/dist-packages/amqp/transport.py", line 294, in create_transport
return TCPTransport(host, connect_timeout)
File "/usr/lib/python3/dist-packages/amqp/transport.py", line 95, in __init__
raise socket.error(last_err)
OSError: [Errno 111] Connection refused
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/lib/python3.4/runpy.py", line 170, in _run_module_as_main
"__main__", mod_spec)
File "/usr/lib/python3.4/runpy.py", line 85, in _run_code
exec(code, run_globals)
File "/usr/lib/python3/dist-packages/swh/indexer/producer.py", line 63, in <module>
main()
File "/usr/lib/python3/dist-packages/click/core.py", line 716, in __call__
return self.main(*args, **kwargs)
File "/usr/lib/python3/dist-packages/click/core.py", line 696, in main
rv = self.invoke(ctx)
File "/usr/lib/python3/dist-packages/click/core.py", line 889, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/usr/lib/python3/dist-packages/click/core.py", line 534, in invoke
return callback(*args, **kwargs)
File "/usr/lib/python3/dist-packages/swh/indexer/producer.py", line 57, in main
run_with_limit(int(limit), batch)
File "/usr/lib/python3/dist-packages/swh/indexer/producer.py", line 40, in run_with_limit
orchestrator_task.delay(sha1s)
File "/usr/lib/python3/dist-packages/celery/app/task.py", line 453, in delay
return self.apply_async(args, kwargs)
File "/usr/lib/python3/dist-packages/celery/app/task.py", line 555, in apply_async
**dict(self._get_exec_options(), **options)
File "/usr/lib/python3/dist-packages/celery/app/base.py", line 353, in send_task
reply_to=reply_to or self.oid, **options
File "/usr/lib/python3/dist-packages/celery/app/amqp.py", line 305, in publish_task
**kwargs
File "/usr/lib/python3/dist-packages/kombu/messaging.py", line 168, in publish
routing_key, mandatory, immediate, exchange, declare)
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 457, in _ensured
interval_max)
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 369, in ensure_connection
interval_start, interval_step, interval_max, callback)
File "/usr/lib/python3/dist-packages/kombu/utils/__init__.py", line 243, in retry_over_time
return fun(*args, **kwargs)
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 237, in connect
return self.connection
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 741, in connection
self._connection = self._establish_connection()
File "/usr/lib/python3/dist-packages/kombu/connection.py", line 696, in _establish_connection
conn = self.transport.establish_connection()
File "/usr/lib/python3/dist-packages/kombu/transport/pyamqp.py", line 112, in establish_connection
conn = self.Connection(**opts)
File "/usr/lib/python3/dist-packages/amqp/connection.py", line 165, in __init__
self.transport = create_transport(host, connect_timeout, ssl)
File "/usr/lib/python3/dist-packages/amqp/transport.py", line 294, in create_transport
return TCPTransport(host, connect_timeout)
File "/usr/lib/python3/dist-packages/amqp/transport.py", line 95, in __init__
raise socket.error(last_err)
OSError: [Errno 111] Connection refused

Event Timeline

ardumont created this paste.Oct 10 2016, 4:07 PM
ardumont changed the title of this paste from connection error when producing message for orchestrator to [invalid] connection error when producing message for orchestrator - ardumont not in swhworker group!.Oct 10 2016, 4:12 PM
About · Developer information · Legal