Skip to content

Commit

Permalink
Fix a few typos (#4131)
Browse files Browse the repository at this point in the history
  • Loading branch information
rs2 authored Sep 29, 2020
1 parent bd5bff0 commit 111029d
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion distributed/semaphore.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down
2 changes: 1 addition & 1 deletion distributed/tests/test_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
6 changes: 3 additions & 3 deletions distributed/tests/test_steal.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand All @@ -166,15 +166,15 @@ 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))

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)
Expand Down
2 changes: 1 addition & 1 deletion docs/source/http_services.rst
Original file line number Diff line number Diff line change
Expand Up @@ -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``.


Expand Down

0 comments on commit 111029d

Please sign in to comment.