summaryrefslogtreecommitdiffstats
path: root/func
diff options
context:
space:
mode:
authorKrzysztof A. Adamski <krzysztofa@gmail.com>2008-06-04 12:18:39 -0400
committerKrzysztof A. Adamski <krzysztofa@gmail.com>2008-06-04 12:18:39 -0400
commitcb63b958f46f21624f3b9bb00f1cc92aaf61da70 (patch)
tree1075bb31d7376a486b76ef812d0de76c8dd77c14 /func
parent6e61c3a5cd9da2e145b37debd30dd28ba63b7070 (diff)
downloadthird_party-func-cb63b958f46f21624f3b9bb00f1cc92aaf61da70.tar.gz
third_party-func-cb63b958f46f21624f3b9bb00f1cc92aaf61da70.tar.xz
third_party-func-cb63b958f46f21624f3b9bb00f1cc92aaf61da70.zip
Change parameter names to match comments and similar funtion in forkbomb.
Diffstat (limited to 'func')
-rw-r--r--func/jobthing.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/func/jobthing.py b/func/jobthing.py
index 1c4d6cc..ea8d92c 100644
--- a/func/jobthing.py
+++ b/func/jobthing.py
@@ -101,7 +101,7 @@ def __access_status(jobid=0, status=0, results=0, clear=False, write=False, purg
return rc
-def batch_run(server, process_server, nforks):
+def batch_run(pool, callback, nforks):
"""
This is the method used by the overlord side usage of jobthing.
Minion side usage will use minion_async_run instead.
@@ -120,7 +120,7 @@ def batch_run(server, process_server, nforks):
# kick off the job
# I don't thing it's needed - kaa
#__update_status(job_id, JOB_ID_RUNNING, -1)
- results = forkbomb.batch_run(server, process_server, nforks)
+ results = forkbomb.batch_run(pool, callback, nforks)
# we now have a list of job id's for each minion, kill the task
__update_status(job_id, JOB_ID_ASYNC_PARTIAL, results)