Apply suggestions from code review

Co-authored-by: Hendrik Makait <hendrik.makait@gmail.com>
fjetter · Aug 20, 2024 · f7bbd44 · f7bbd44
1 parent 93f4c6f
commit f7bbd44
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/distributed/queues.py b/distributed/queues.py
@@ -72,7 +72,7 @@ async def put(self, name=None, key=None, data=None, client=None, timeout=None):
             while key not in self.scheduler.tasks:
                 await asyncio.sleep(0.01)
                 if deadline.expired:
-                    raise TimeoutError(f"Task {key} unknown to scheudler.")
+                    raise TimeoutError(f"Task {key} unknown to scheduler.")
 
             record = {"type": "Future", "value": key}
             self.future_refcount[name, key] += 1

diff --git a/distributed/tests/test_queues.py b/distributed/tests/test_queues.py
@@ -341,5 +341,5 @@ async def test_set_cancelled_future(c, s):
     q = Queue("x")
     # FIXME: This is a TimeoutError but pytest doesn't appear to recognize it as
     # such
-    with pytest.raises(Exception, match="unknown to scheudler"):
+    with pytest.raises(Exception, match="unknown to scheduler"):
         await q.put(x, timeout="100ms")
diff --git a/distributed/variable.py b/distributed/variable.py
@@ -51,7 +51,7 @@ async def set(self, name=None, key=None, data=None, client=None, timeout=None):
             while key not in self.scheduler.tasks:
                 await asyncio.sleep(0.01)
                 if deadline.expired:
-                    raise TimeoutError(f"Task {key} unknown to scheudler.")
+                    raise TimeoutError(f"Task {key} unknown to scheduler.")
             self.scheduler.client_desires_keys(keys=[key], client="variable-%s" % name)
         else:
             record = {"type": "msgpack", "value": data}