diff options
Diffstat (limited to 'func')
| -rw-r--r-- | func/forkbomb.py (renamed from func/overlord/forkbomb.py) | 0 | ||||
| -rw-r--r-- | func/jobthing.py (renamed from func/overlord/jobthing.py) | 3 | ||||
| -rwxr-xr-x | func/overlord/client.py | 4 |
3 files changed, 5 insertions, 2 deletions
diff --git a/func/overlord/forkbomb.py b/func/forkbomb.py index c30cc9e..c30cc9e 100644 --- a/func/overlord/forkbomb.py +++ b/func/forkbomb.py diff --git a/func/overlord/jobthing.py b/func/jobthing.py index e405616..4923daa 100644 --- a/func/overlord/jobthing.py +++ b/func/jobthing.py @@ -90,6 +90,9 @@ def __access_status(jobid=0, status=0, results=0, clear=False, write=False): def batch_run(server, process_server, nforks): """ + This is the method used by the overlord side usage of jobthing. + It likely makes little sense for the minion async usage (yet). + Given an array of items (pool), call callback in each one, but divide the workload over nfork forks. Temporary files used during the operation will be created in cachedir and subsequently deleted. diff --git a/func/overlord/client.py b/func/overlord/client.py index 60b5c24..98edaed 100755 --- a/func/overlord/client.py +++ b/func/overlord/client.py @@ -22,8 +22,8 @@ from func.config import read_config, CONFIG_FILE import sslclient import command -import forkbomb -import jobthing +import func.forkbomb as forkbomb +import func.jobthing as jobthing # =================================== # defaults |