tmp

dask · Feb 3, 2021 · dabaea3 · dabaea3
1 parent 0e35b49
commit dabaea3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/distributed/comm/utils.py b/distributed/comm/utils.py
@@ -108,7 +108,7 @@ def _to_frames():
         msg_size = 0
 
     if is_msgpack_serializable(msg):
-        print("to_frames() SIMPLE: ", repr(msg))
+        #print("to_frames() SIMPLE: ", repr(msg))
         if context and "compression" in context:
             compress_opts = {"compression": context["compression"]}
         else:
@@ -121,7 +121,7 @@ def _to_frames():
             )
     else:
         pass
-        print("to_frames() NON-SIMPLE: ", repr(msg))
+        #print("to_frames() NON-SIMPLE: ", repr(msg))
 
     if allow_offload and OFFLOAD_THRESHOLD and msg_size > OFFLOAD_THRESHOLD:
         return await offload(_to_frames)