enable traffic compression

sequence-toolbox · Jun 2, 2021 · eea422f · eea422f
1 parent d9642e2
commit eea422f
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/kernel/quantum_manager_client.py b/src/kernel/quantum_manager_client.py
@@ -207,11 +207,9 @@ def _send_message(self, msg_type, keys: List, args: List,
 
         msg = QuantumManagerMessage(msg_type, keys, args)
         self.message_buffer.append(msg)
-        self.flush_message_buffer()
 
         if expecting_receive:
-            # TRAFFIC COMPRESS
-            # self.flush_message_buffer()
+            self.flush_message_buffer()
             tick = time()
             received_msg = recv_msg_with_length(self.socket)
             self.io_time += time() - tick