Exception in the Redis discovery module

[tcalmant]

This error can appear when starting multiple frameworks in parallel while some traces of lost frameworks are still stored in Redis.

WARNING:pelix.remote.dispatcher:No exporters yet.
INFO:httpd:Starting HTTP server: [0.0.0.0]:8080 ...
INFO:httpd:HTTP server started: [0.0.0.0]:8080
Exception in thread Thread-1:
Traceback (most recent call last):
  File "/opt/conda/lib/python3.5/site-packages/pelix/remote/discovery/redis.py", line 412, in _handle_set
    hostname = self._frameworks_hosts[fw_uid]
KeyError: '5e4b3e50-2c33-46d5-99d0-14ed143e931b'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/opt/conda/lib/python3.5/threading.py", line 914, in _bootstrap_inner
    self.run()
  File "/opt/conda/lib/python3.5/site-packages/redis/client.py", line 2345, in run
    timeout=sleep_time)
  File "/opt/conda/lib/python3.5/site-packages/redis/client.py", line 2262, in get_message
    return self.handle_message(response, ignore_subscribe_messages)
  File "/opt/conda/lib/python3.5/site-packages/redis/client.py", line 2307, in handle_message
    handler(message)
  File "/opt/conda/lib/python3.5/site-packages/pelix/remote/discovery/redis.py", line 384, in _handle_endpoint_event
    method(data['channel'].decode('utf-8').split(':', 1)[1])
  File "/opt/conda/lib/python3.5/site-packages/pelix/remote/discovery/redis.py", line 416, in _handle_set
    PATTERN_FRAMEWORK_KEY.format(fw_uid=fw_uid)) \
AttributeError: 'NoneType' object has no attribute 'decode'

ERROR:pelix.threadpool:Error executing _run: 'NoneType' object has no attribute 'store_line'
Traceback (most recent call last):
  File "/root/sparkcontroller/agents/worker.py", line 159, in _run
    self._send_message(cmd_uuid, line)
  File "/root/sparkcontroller/agents/worker.py", line 180, in _send_message
    self._master.store_line(cmd_uuid, self._id, time.time(), line)
AttributeError: 'NoneType' object has no attribute 'store_line'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/opt/conda/lib/python3.5/site-packages/pelix/threadpool.py", line 405, in __run
    future.execute(method, args, kwargs)
  File "/opt/conda/lib/python3.5/site-packages/pelix/threadpool.py", line 119, in execute
    result = method(*args, **kwargs)
  File "/root/sparkcontroller/agents/worker.py", line 169, in _run
    cmd_uuid, "Error running command: {0}".format(ex))
  File "/root/sparkcontroller/agents/worker.py", line 180, in _send_message
    self._master.store_line(cmd_uuid, self._id, time.time(), line)
AttributeError: 'NoneType' object has no attribute 'store_line'
ERROR:pelix.threadpool:Error executing _run: 'NoneType' object has no attribute 'store_line'
Traceback (most recent call last):
  File "/root/sparkcontroller/agents/worker.py", line 159, in _run
    self._send_message(cmd_uuid, line)
  File "/root/sparkcontroller/agents/worker.py", line 180, in _send_message
    self._master.store_line(cmd_uuid, self._id, time.time(), line)
AttributeError: 'NoneType' object has no attribute 'store_line'

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/opt/conda/lib/python3.5/site-packages/pelix/threadpool.py", line 405, in __run
    future.execute(method, args, kwargs)
  File "/opt/conda/lib/python3.5/site-packages/pelix/threadpool.py", line 119, in execute
    result = method(*args, **kwargs)
  File "/root/sparkcontroller/agents/worker.py", line 169, in _run
    cmd_uuid, "Error running command: {0}".format(ex))
  File "/root/sparkcontroller/agents/worker.py", line 180, in _send_message
    self._master.store_line(cmd_uuid, self._id, time.time(), line)
AttributeError: 'NoneType' object has no attribute 'store_line'