Merge pull request #6 from autonomio/#distributescan_features

#get jako work like talos.DistributeScan

jako/__init__.py

@@ -1,3 +1,3 @@
 from .distribute.DistributedScan import DistributedScan
-
+from .distribute.RemoteScan import RemoteScan
 del distribute

jako/distribute/RemoteScan.py

@@ -1,4 +1,4 @@
-from talos.scan.Scan import Scan
+from talos import Scan
 
 
 class RemoteScan(Scan):

jako/distribute/distribute_params.py

@@ -1,4 +1,4 @@
-from talos.scan.Scan import Scan
+from talos import Scan
 from .distribute_utils import read_config, write_config
 
 

jako/distribute/distribute_run.py

@@ -78,13 +78,13 @@ def distribute_run(self):
 
         if run_central_node:
 
-            args = args=(self, n_splits, run_central_node)
+            args = (self, n_splits, run_central_node)
             thread = threading.Thread(target=run_central_machine, args=args)
             thread.start()
             threads.append(thread)
 
             args = ([self, update_db_n_seconds, current_machine_id,self.stage])
-            threads = threading.Thread(target=update_db, args=args)
+            thread = threading.Thread(target=update_db, args=args)
             thread.start()
             threads.append(thread)
 

jako/distribute/distribute_utils.py

@@ -6,7 +6,7 @@
 
 def create_temp_file(self):
     filestr = '''
-from talos import RemoteScan
+from jako import RemoteScan
 import numpy as np
 import json
 import pickle

jako/distribute/script_string.py

@@ -1,7 +1,7 @@
 def script_script():
 
     out = '''
-from talos import RemoteScan
+from jako import RemoteScan
 import numpy as np
 import json
 import pickle