commit abd6ead9fc5dde4d3d2ba13133fc67b5e130d9ca
author koder aka kdanilov <kdanilov@mirantis.com> Fri Apr 24 02:03:07 2015 +0300
committer koder aka kdanilov <kdanilov@mirantis.com> Fri Apr 24 02:03:07 2015 +0300
tree 69db389d7528ce128032a4df235503243b367556
parent afd98748dbb15d1eaea0b7a634e787f7fa4134dc

fixes, fixes, fixes

wally/run_test.py

diff --git a/wally/run_test.py b/wally/run_test.py
index 0b20657..07ac6e3 100755
--- a/wally/run_test.py
+++ b/wally/run_test.py
@@ -118,7 +118,7 @@
         test_cls = tool_type_mapper[name]
         rem_folder = cfg['default_test_local_folder'].format(name=name)
 
-        for node in test_nodes:
+        for idx, node in enumerate(test_nodes):
             msg = "Starting {0} test on {1} node"
             logger.debug(msg.format(name, node.conn_url))
 
@@ -130,7 +130,11 @@
             if not os.path.exists(dr):
                 os.makedirs(dr)
 
-            test = test_cls(params, res_q.put, cfg['run_uuid'], node,
+            test = test_cls(options=params,
+                            is_primary=(idx == 0),
+                            on_result_cb=res_q.put,
+                            test_uuid=cfg['run_uuid'],
+                            node=node,
                             remote_dir=rem_folder,
                             log_directory=dr,
                             coordination_queue=coord_q)