Skip to content

Commit 22599bb

Browse files
author
Daniel Blanchard
committed
Add info about the queue keyword argument to examples.
1 parent 28bce7e commit 22599bb

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

examples/manual.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,9 @@ def make_jobs():
7575

7676
# create job objects
7777
for arg in inputvec:
78-
job = Job(compute_factorial, arg)
78+
# The default queue used by the Job class is all.q. You must specify
79+
# the `queue` keyword argument if that is not the name of your queue.
80+
job = Job(compute_factorial, arg, queue='all.q')
7981
jobs.append(job)
8082

8183
return jobs

examples/map_reduce.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,10 @@ def main():
7070

7171
args = [3, 5, 10, 20]
7272

73+
# The default queue used by grid_map is all.q. You must specify
74+
# the `queue` keyword argument if that is not the name of your queue.
7375
intermediate_results = grid_map(computeFactorial, args, quiet=False,
74-
max_processes=4)
76+
max_processes=4, queue='all.q')
7577

7678
# Just print the items instead of really reducing. We could always sum them.
7779
print("reducing result")

0 commit comments

Comments
 (0)