Skip to content

Commit

Permalink
Updating start_workers to scale in examples (#453)
Browse files Browse the repository at this point in the history
Co-authored-by: Loïc Estève <loic.esteve@ymail.com>
  • Loading branch information
vsoch and lesteve committed Jul 27, 2020
1 parent d7afbfe commit 62036af
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion dask_jobqueue/tests/test_lsf.py
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,7 @@ def test_basic(loop):
loop=loop,
) as cluster:
with Client(cluster) as client:
cluster.start_workers(2)
cluster.scale(2)
assert cluster.pending_jobs or cluster.running_jobs
future = client.submit(lambda x: x + 1, 10)
assert future.result(QUEUE_WAIT) == 11
Expand Down
2 changes: 1 addition & 1 deletion docs/source/examples.rst
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ to the dask-workers.
cores=2,
extra=['--resources ssdGB=200,GPU=2'])
cluster.start_workers(2)
cluster.scale(2)
client = Client(cluster)
The client can then be used as normal. Additionally, required resources can be
Expand Down

0 comments on commit 62036af

Please sign in to comment.