summaryrefslogtreecommitdiffstats
path: root/func
diff options
context:
space:
mode:
authorKrzysztof A. Adamski <krzysztofa@gmail.com>2008-06-06 18:17:50 -0400
committerKrzysztof A. Adamski <krzysztofa@gmail.com>2008-06-06 18:17:50 -0400
commit58439ecd3433434b8fa31821619fec8e5bbeda27 (patch)
treea1e96e12d797da2744b727ad49d8a3cd806a32f4 /func
parent2d23caf2f9e96022dd49781bc00c351dcab7c10c (diff)
downloadthird_party-func-58439ecd3433434b8fa31821619fec8e5bbeda27.tar.gz
third_party-func-58439ecd3433434b8fa31821619fec8e5bbeda27.tar.xz
third_party-func-58439ecd3433434b8fa31821619fec8e5bbeda27.zip
Cleanup: 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 bbc4f89..c7eb179 100644
--- a/func/jobthing.py
+++ b/func/jobthing.py
@@ -99,7 +99,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.
@@ -117,7 +117,7 @@ def batch_run(server, process_server, nforks):
else:
# kick off the job
__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_PARTIAL, results)