48373446ecf9ef563b02c360be347da02df09ce9,deeppavlov/utils/socket/socket.py,,handle_connection,#Any#Any#Any#Any#Any#,21

Before Change

        return
    elif len(lengths) > 1:
        log.error("got several different batch sizes")
        await loop.sock_sendall(conn, b"[]")
        return
    batch_size = list(lengths)[0]
    model_args = [arg or [None] * batch_size for arg in model_args]

After Change

    try:
        while True:
            chunk = await loop.run_in_executor(None, conn.recv, bufsize)
            if chunk:
                recv_data += chunk
            else:
                break
    except BlockingIOError:
        pass
    try:
        data = json.loads(recv_data)

Instances