Skip to content

Commit 4f1f493

Browse files
committed
Simply call sum on sizes for bytes sent
1 parent 249c84a commit 4f1f493

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

distributed/comm/ucx.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ async def write(
206206

207207
for each_frame in send_frames:
208208
await self.ep.send(each_frame)
209-
return sum(map(nbytes, send_frames))
209+
return sum(sizes)
210210
except (ucp.exceptions.UCXBaseException):
211211
self.abort()
212212
raise CommClosedError("While writing, the connection was closed")

0 commit comments

Comments
 (0)