Skip to content

Commit 291de5d

Browse files
fjettercrusaderky
andauthored
Apply suggestions from code review
Co-authored-by: crusaderky <crusaderky@gmail.com>
1 parent bad077e commit 291de5d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

distributed/batched.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ def _background_send(self):
113113
logger.exception("Error in batched write")
114114
break
115115
finally:
116-
# If anything failed we should not loose payload. If a new comm
116+
# If anything failed we should not lose payload. If a new comm
117117
# is provided we can still resubmit messages
118118
self.buffer = payload + self.buffer
119119
else:

distributed/tests/test_worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3197,7 +3197,7 @@ async def test_deadlock_cancelled_after_inflight_before_gather_from_worker(
31973197

31983198

31993199
@gen_cluster(nthreads=[("", 1)])
3200-
async def test_dont_loose_payload_reconnect(s, w):
3200+
async def test_dont_lose_payload_reconnect(s, w):
32013201
"""Ensure that payload of a BatchedSend is not lost if a worker reconnects"""
32023202
s.count = 0
32033203

0 commit comments

Comments
 (0)