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

Before Change

        if param_value is None or (isinstance(param_value, list) and len(param_value) > 0):
            model_args.append(param_value)
        else:
            log.error(f"nonempty array expected but got "{param_name}"={repr(param_value)}")
            await loop.sock_sendall(conn, b"[]")
            return
    lengths = {len(i) for i in model_args if i is not None}

After Change

    recv_data = b""
    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