Inline join call

Also leave comment on its own line above.
dask · Nov 20, 2020 · 17f6ef5 · 17f6ef5
1 parent 3a25352
commit 17f6ef5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/distributed/comm/tcp.py b/distributed/comm/tcp.py
@@ -237,8 +237,8 @@ async def write(self, msg, serializers=None, on_error="message"):
             lengths = [nbytes(frame) for frame in frames]
             length_bytes = struct.pack(f"Q{nframes}Q", nframes, *lengths)
             if sum(lengths) < 2 ** 17:  # 128kiB
-                b = b"".join([length_bytes, *frames])  # small enough, send in one go
-                stream.write(b)
+                # small enough, send in one go
+                stream.write(b"".join([length_bytes, *frames]))
             else:
                 # avoid large memcpy, send in many
                 stream.write(length_bytes)