From 111029d53536d596043feee2a8c914fb680774bd Mon Sep 17 00:00:00 2001 From: Pav A Date: Tue, 29 Sep 2020 18:56:09 +0100 Subject: [PATCH] Fix a few typos (#4131) --- distributed/semaphore.py | 2 +- distributed/tests/test_client.py | 2 +- distributed/tests/test_steal.py | 6 +++--- docs/source/http_services.rst | 2 +- 4 files changed, 6 insertions(+), 6 deletions(-) diff --git a/distributed/semaphore.py b/distributed/semaphore.py index 5d86bd8ea59..6ff66eac811 100644 --- a/distributed/semaphore.py +++ b/distributed/semaphore.py @@ -386,7 +386,7 @@ def __init__(self, max_leases=1, name=None, client=None, register=True): self.client._periodic_callbacks[self._periodic_callback_name] = pc # Need to start the callback using IOLoop.add_callback to ensure that the - # PC uses the correct event lopp. + # PC uses the correct event loop. self.client.io_loop.add_callback(pc.start) def register(self): diff --git a/distributed/tests/test_client.py b/distributed/tests/test_client.py index e2251d82b53..846e098a11d 100644 --- a/distributed/tests/test_client.py +++ b/distributed/tests/test_client.py @@ -6130,7 +6130,7 @@ async def f(): @pytest.mark.asyncio -async def test_client_gather_semaphor_loop(cleanup): +async def test_client_gather_semaphore_loop(cleanup): async with Scheduler(port=0) as s: async with Client(s.address, asynchronous=True) as c: assert c._gather_semaphore._loop is c.loop.asyncio_loop diff --git a/distributed/tests/test_steal.py b/distributed/tests/test_steal.py index 5ef3e5330ec..f6fb91b1ce2 100644 --- a/distributed/tests/test_steal.py +++ b/distributed/tests/test_steal.py @@ -149,7 +149,7 @@ async def test_dont_steal_fast_tasks_compute_time(c, s, *workers): def do_nothing(x, y=None): pass - # execute and meassure runtime once + # execute and measure runtime once await wait(c.submit(do_nothing, 1)) futures = c.map(do_nothing, range(1000), y=x) @@ -166,7 +166,7 @@ async def test_dont_steal_fast_tasks_blacklist(c, s, a, b): x = c.submit(slowinc, 1, workers=[b.address]) # If the blacklist of fast tasks is tracked somewhere else, this needs to be - # changed. This test requies *any* key which is blacklisted. + # changed. This test requires *any* key which is blacklisted. from distributed.stealing import fast_tasks blacklisted_key = next(iter(fast_tasks)) @@ -174,7 +174,7 @@ async def test_dont_steal_fast_tasks_blacklist(c, s, a, b): def fast_blacklisted(x, y=None): # The task should observe a certain computation time such that we can # ensure that it is not stolen due to the blacklisting. If it is too - # fast, the standard mechansim shouldn't allow stealing + # fast, the standard mechanism shouldn't allow stealing import time time.sleep(0.01) diff --git a/docs/source/http_services.rst b/docs/source/http_services.rst index ef5b7527957..d94485319a9 100644 --- a/docs/source/http_services.rst +++ b/docs/source/http_services.rst @@ -2,7 +2,7 @@ HTTP endpoints ============== A subset of the following pages will be available from the scheduler or -workers of a running cluster. The list of currently available endpoins can +workers of a running cluster. The list of currently available endpoints can be found by examining ``/sitemap.json``.