blissdata BeaconClient bug
def _read(self, expected_message_key):
data = b""
while True:
raw_data = self._connection.recv(16 * 1024)
if not raw_data:
break >>> message is not defined
data = b"%s%s" % (data, raw_data)
try:
message_type, message, data = self._unpack_message(data)
except IncompleteBeaconMessage:
continue
break
message_key, data = self._get_msg_key(message) >>> raises exception
if message_key != expected_message_key:
raise RuntimeError(f"Unexpected message key '{message_key}'")
return message_type, data
Traceback (most recent call last):
File "/home/denolf/dev/ewoksjob/src/ewoksjob/config.py", line 45, in read_configuration
config = read_configuration(cfg_uri=cfg_uri)
File "/home/denolf/dev/ewoksjob/src/ewoksjob/config.py", line 99, in read_configuration
config = _read_yaml_config(cfg_uri)
File "/home/denolf/dev/ewoksjob/src/ewoksjob/config.py", line 145, in _read_yaml_config
return bliss_read_config(resource)
File "/home/denolf/dev/bliss/blissdata/blissdata/beacon/files.py", line 35, in read_config
return _read_config_beacon(url)
File "/home/denolf/dev/bliss/blissdata/blissdata/beacon/files.py", line 87, in _read_config_beacon
config = beacon.get_file(file_path)
File "/home/denolf/dev/bliss/blissdata/blissdata/beacon/files.py", line 119, in get_file
response_type, data = response.read()
File "/home/denolf/dev/bliss/blissdata/blissdata/beacon/_base.py", line 61, in read
return client._read(message_key)
File "/home/denolf/dev/bliss/blissdata/blissdata/beacon/_base.py", line 97, in _read
message_key, data = self._get_msg_key(message)
UnboundLocalError: local variable 'message' referenced before assignment