Loading sender.py +1 −1 Original line number Diff line number Diff line Loading @@ -25,7 +25,7 @@ metadata_str = json.dumps(md) pubsocket.send_string("metadata", flags=zmq.SNDMORE) pubsocket.send_string(metadata_str) chunk_size = 100 chunk_size = 10 total_chunks = len(aryinit) // chunk_size + (1 if len(aryinit) % chunk_size else 0) for i in range(total_chunks): Loading Loading
sender.py +1 −1 Original line number Diff line number Diff line Loading @@ -25,7 +25,7 @@ metadata_str = json.dumps(md) pubsocket.send_string("metadata", flags=zmq.SNDMORE) pubsocket.send_string(metadata_str) chunk_size = 100 chunk_size = 10 total_chunks = len(aryinit) // chunk_size + (1 if len(aryinit) % chunk_size else 0) for i in range(total_chunks): Loading