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

on the minion for minion side async funness.

5 files changed, 8 insertions, 4 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
diff --git a/test/async_test.py b/test/async_test.py
index 4c1acf5..43904c4 100644
--- a/test/async_test.py
+++ b/test/async_test.py
@@ -1,5 +1,5 @@
 from func.overlord.client import Client
-import func.overlord.jobthing as jobthing
+import func.jobthing as jobthing
 import time
 import sys
 
diff --git a/test/unittest/test_client.py b/test/unittest/test_client.py
index 12cb40b..f4f2029 100644
--- a/test/unittest/test_client.py
+++ b/test/unittest/test_client.py
@@ -5,11 +5,12 @@ import unittest
 import xmlrpclib
 
 import func.overlord.client as fc
+import socket
 
 
 
 class BaseTest:
-    th = "grimlock.devel.redhat.com"
+    th = "mdehaan.rdu.redhat.com"
     def __init__(self):
         pass