Moving the async and multiprocess stuff to top level so we can use them

on the minion for minion side async funness.

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