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