python3 run_cluster.py
INFO:root:('/home/user/dev/logs', '127.0.0.1:8002', {'127.0.0.1:8001', '127.0.0.1:8000'})
INFO:root:('/home/user/dev/logs', '127.0.0.1:8001', {'127.0.0.1:8002', '127.0.0.1:8000'})
INFO:root:('/home/user/dev/logs', '127.0.0.1:8000', {'127.0.0.1:8002', '127.0.0.1:8001'})
ERROR:asyncio:Exception in callback _SelectorDatagramTransport._read_ready()
handle: <Handle _SelectorDatagramTransport._read_ready()>
Traceback (most recent call last):
File "/usr/lib/python3.6/asyncio/events.py", line 127, in _run
self._callback(self._args)
File "/usr/lib/python3.6/asyncio/selector_events.py", line 1078, in _read_ready
self._protocol.datagram_received(data, addr)
File "/usr/local/lib/python3.6/dist-packages/raftos/network.py", line 33, in datagram_received
self.request_handler(data)
File "/usr/local/lib/python3.6/dist-packages/raftos/server.py", line 73, in request_handler
self.state.request_handler(data)
File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 534, in request_handler
getattr(self.state, 'onreceive{}'.format(data['type']))(data)
File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 56, in wrapped
return func(self, args, **kwargs)
File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 38, in on_receive_function
return func(self, data)
File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 219, in on_receive_append_entries_response
if data['request_id'] in self.response_map:
KeyError: 'request_id'
python3 run_cluster.py INFO:root:('/home/user/dev/logs', '127.0.0.1:8002', {'127.0.0.1:8001', '127.0.0.1:8000'}) INFO:root:('/home/user/dev/logs', '127.0.0.1:8001', {'127.0.0.1:8002', '127.0.0.1:8000'}) INFO:root:('/home/user/dev/logs', '127.0.0.1:8000', {'127.0.0.1:8002', '127.0.0.1:8001'}) ERROR:asyncio:Exception in callback _SelectorDatagramTransport._read_ready() handle: <Handle _SelectorDatagramTransport._read_ready()> Traceback (most recent call last): File "/usr/lib/python3.6/asyncio/events.py", line 127, in _run self._callback(self._args) File "/usr/lib/python3.6/asyncio/selector_events.py", line 1078, in _read_ready self._protocol.datagram_received(data, addr) File "/usr/local/lib/python3.6/dist-packages/raftos/network.py", line 33, in datagram_received self.request_handler(data) File "/usr/local/lib/python3.6/dist-packages/raftos/server.py", line 73, in request_handler self.state.request_handler(data) File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 534, in request_handler getattr(self.state, 'onreceive{}'.format(data['type']))(data) File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 56, in wrapped return func(self, args, **kwargs) File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 38, in on_receive_function return func(self, data) File "/usr/local/lib/python3.6/dist-packages/raftos/state.py", line 219, in on_receive_append_entries_response if data['request_id'] in self.response_map: KeyError: 'request_id'