Commit 146b188a authored by Benjamin Blanc's avatar Benjamin Blanc

Save before changements

parent 89d983cc
...@@ -39,12 +39,16 @@ import string ...@@ -39,12 +39,16 @@ import string
import random import random
from ProcessManager import SubprocessError, ProcessManager, CancellationError from ProcessManager import SubprocessError, ProcessManager, CancellationError
from subprocess import CalledProcessError from subprocess import CalledProcessError
from NodeTestSuite import SlapOSInstance
from Updater import Updater from Updater import Updater
from erp5.util import taskdistribution from erp5.util import taskdistribution
class UnitTestRunner(object): class UnitTestRunner(object):
def __init__(self, testnode): def __init__(self, testnode):
pass self.testnode = testnode
self.test_node_slapos = SlapOSInstance()
self.test_node_slapos.edit(working_directory=self.testnode.config['slapos_directory'])
......
...@@ -108,8 +108,5 @@ def main(*args): ...@@ -108,8 +108,5 @@ def main(*args):
CONFIG['software_list'] = filter(None, CONFIG['software_list'] = filter(None,
config.get("software_list", "path_list").split(",")) config.get("software_list", "path_list").split(","))
# Here : can we know the test type (scalability or unittest) ?
# If it's possible, :
# testnode = Testnode / ScalabilityTestNode
testnode = TestNode(logger.info, CONFIG) testnode = TestNode(logger.info, CONFIG)
testnode.run() testnode.run()
...@@ -471,8 +471,9 @@ class TestNode(BaseTestNode): ...@@ -471,8 +471,9 @@ class TestNode(BaseTestNode):
previous_revision_dict = {} previous_revision_dict = {}
revision_dict = {} revision_dict = {}
test_result = None test_result = None
test_node_slapos = SlapOSInstance()
test_node_slapos.edit(working_directory=self.config['slapos_directory']) runner = UnitTestRunner(self)
try: try:
while True: while True:
try: try:
...@@ -481,7 +482,6 @@ class TestNode(BaseTestNode): ...@@ -481,7 +482,6 @@ class TestNode(BaseTestNode):
self.cleanUp(None) self.cleanUp(None)
remote_test_result_needs_cleanup = False remote_test_result_needs_cleanup = False
begin = time.time() begin = time.time()
self.prepareSlapOSForTestNode(test_node_slapos)
portal_url = config['test_suite_master_url'] portal_url = config['test_suite_master_url']
portal = taskdistribution.TaskDistributionTool(portal_url, logger=DummyLogger(log)) portal = taskdistribution.TaskDistributionTool(portal_url, logger=DummyLogger(log))
test_suite_portal = taskdistribution.TaskDistributor(portal_url, logger=DummyLogger(log)) test_suite_portal = taskdistribution.TaskDistributor(portal_url, logger=DummyLogger(log))
...@@ -489,6 +489,11 @@ class TestNode(BaseTestNode): ...@@ -489,6 +489,11 @@ class TestNode(BaseTestNode):
test_suite_data = deunicodeData(json.loads(test_suite_json)) test_suite_data = deunicodeData(json.loads(test_suite_json))
log("Got following test suite data from master : %r" % \ log("Got following test suite data from master : %r" % \
(test_suite_data,)) (test_suite_data,))
# Here we know what we are (sclability or unit test)
# change the line below to runner.prepareSlapOSForTestNode ..
self.prepareSlapOSForTestNode(runner.test_node_slapos)
#Clean-up test suites #Clean-up test suites
self.checkOldTestSuite(test_suite_data) self.checkOldTestSuite(test_suite_data)
for test_suite in test_suite_data: for test_suite in test_suite_data:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment