Fixed hanging process race
@@ -1011,6 +1011,11 @@ class RunManager(object):
parse = False
while True:
res = bytearray()
+ # We received multiple messages from the last socket read
+ if payload.find(b'\0') != -1:
+ res = payload
+ payload = b''
+ else:
try:
res = self._socket.recv(1024)
except socket.error as e:
