Skip to content

Commit

Permalink
Include maximum shard size in second to_frames method (#5145)
Browse files Browse the repository at this point in the history
Websockets are weird in that they have two different Comm objects.
Previously we added the maximum shard size setting to one,
but not the other
  • Loading branch information
mrocklin authored Jul 30, 2021
1 parent 595abbf commit 3f1b250
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions distributed/comm/ws.py
Original file line number Diff line number Diff line change
Expand Up @@ -216,6 +216,7 @@ async def write(self, msg, serializers=None, on_error=None):
"recipient": self.remote_info,
**self.handshake_options,
},
frame_split_size=BIG_BYTES_SHARD_SIZE,
)
n = struct.pack("Q", len(frames))
try:
Expand Down

0 comments on commit 3f1b250

Please sign in to comment.