9db1c1d7060f26f3d871d72d5a5690c073d67ade,service/server.py,BertServer,run,#BertServer#,47

Before Change

                free_a_worker(worker)
                if client != b"READY" and len(request) > 3:
                    for j in request:
                        print(j)
                        input()
                    _, reply = request[3:]
                    finish_jobs[client].append(pickle.loads(reply))
                else:

After Change

                worker, _, client = request[:3]
                free_a_worker(worker)
                if client != b"READY" and len(request) > 3:
                    arr_info, arr_val = jsonapi.loads(request[4]), request[7]
                    X = np.frombuffer(memoryview(arr_val), dtype=arr_info["dtype"])
                    finish_jobs[client].append(X.reshape(arr_info["shape"]))
                else:
                    poller.register(self.frontend, zmq.POLLIN)

Instances