diff options
author | Krzysztof A. Adamski <krzysztofa@gmail.com> | 2008-06-06 18:17:50 -0400 |
---|---|---|
committer | Krzysztof A. Adamski <krzysztofa@gmail.com> | 2008-06-06 18:17:50 -0400 |
commit | 58439ecd3433434b8fa31821619fec8e5bbeda27 (patch) | |
tree | a1e96e12d797da2744b727ad49d8a3cd806a32f4 /func | |
parent | 2d23caf2f9e96022dd49781bc00c351dcab7c10c (diff) | |
download | third_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.py | 4 |
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) |