diff --git a/distributed/queues.py b/distributed/queues.py
index 7a313613ed..e2b0ee6e4d 100644
--- 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
index 6b631f0f17..11e0f379a8 100644
--- 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
index bcc8523fa5..befec99484 100644
--- 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}