pacifica-elasticsearch progress display failure

[karcaw]

Pacifica Elasticsearch version

latest

Platform Details

RHEL7

Scenario:

run the tool

Steps to Reproduce:

run the tool. it fails

Expected Result:

it doesent fail

Actual Result:

it fails:

Total Completed:   0%|                                                                                                                             | 0/9 [00:00<?, ?it/s]
Traceback (most recent call last):███████████████████████████████▉                                                                       | 18/58 [00:18<00:31,  1.26it/s]
  File "/opt/elasticsearch/bin/pacifica-elasticsearch", line 10, in <module>
    sys.exit(main())
  File "/opt/elasticsearch/lib/python3.6/site-packages/pacifica/elasticsearch/__main__.py", line 97, in main
    return args.func(args)
  File "/opt/elasticsearch/lib/python3.6/site-packages/pacifica/elasticsearch/search_sync.py", line 161, in search_sync
    return work_queue.progress(args)
  File "/opt/elasticsearch/lib/python3.6/site-packages/pacifica/elasticsearch/celery.py", line 56, in progress
    if not result.get():  # pragma: no cover failure testing is hard
  File "/opt/elasticsearch/lib/python3.6/site-packages/celery/result.py", line 226, in get
    on_message=on_message,
  File "/opt/elasticsearch/lib/python3.6/site-packages/celery/backends/asynchronous.py", line 188, in wait_for_pending
    for _ in self._wait_for_pending(result, **kwargs):
  File "/opt/elasticsearch/lib/python3.6/site-packages/celery/backends/asynchronous.py", line 255, in _wait_for_pending
    on_interval=on_interval):
  File "/opt/elasticsearch/lib/python3.6/site-packages/celery/backends/asynchronous.py", line 56, in drain_events_until
    yield self.wait_for(p, wait, timeout=1)
  File "/opt/elasticsearch/lib/python3.6/site-packages/celery/backends/asynchronous.py", line 65, in wait_for
    wait(timeout=timeout)
  File "/opt/elasticsearch/lib/python3.6/site-packages/celery/backends/rpc.py", line 63, in drain_events
    return self._connection.drain_events(timeout=timeout)
  File "/opt/elasticsearch/lib/python3.6/site-packages/kombu/connection.py", line 315, in drain_events
    return self.transport.drain_events(self.connection, **kwargs)
  File "/opt/elasticsearch/lib/python3.6/site-packages/kombu/transport/pyamqp.py", line 103, in drain_events
    return connection.drain_events(**kwargs)
  File "/opt/elasticsearch/lib/python3.6/site-packages/amqp/connection.py", line 500, in drain_events
    while not self.blocking_read(timeout):
  File "/opt/elasticsearch/lib/python3.6/site-packages/amqp/connection.py", line 505, in blocking_read
    frame = self.transport.read_frame()
  File "/opt/elasticsearch/lib/python3.6/site-packages/amqp/transport.py", line 252, in read_frame
    frame_header = read(7, True)
  File "/opt/elasticsearch/lib/python3.6/site-packages/amqp/transport.py", line 436, in _read
    s = recv(n - len(rbuf))
ConnectionResetError: [Errno 104] Connection reset by peer

[dmlb2000]

@karcaw Did this still have an issue?

[karcaw]

i believe so.