Merge pull request #66 from weka/loki-only_mode

bigfixes and cleanup

Author: vince-weka

async_api.py

@@ -266,6 +266,7 @@ def __init__(self, cluster, max_procs=8, max_threads_per_proc=100):
         self.max_threads_per_proc = max_threads_per_proc
 
         # # of processes and threads to run...  (self-tuning)
+        cluster_size = self.cluster.sizeof()
         self.num_slaves = math.ceil(self.cluster.sizeof() / self.max_threads_per_proc)
         if self.num_slaves > max_procs:
             self.num_slaves = max_procs   # limit the number of slave processes we start