2 HCE project, Python bindings, Distributed Tasks Manager application. 3 TasksStateUpdateService object functional tests. 6 @author bgv bgv.hce@gmail.com 7 @link: http://hierarchical-cluster-engine.com/ 8 @copyright: Copyright © 2013-2014 IOIX Ukraine 9 @license: http://hierarchical-cluster-engine.com/license/ 26 if __name__ ==
"__main__":
27 logger = logging.getLogger(DTM_CONSTS.LOGGER_NAME)
28 ch = logging.StreamHandler(sys.stdout)
29 ch.setLevel(logging.DEBUG)
30 logger.setLevel(logging.DEBUG)
31 formatter = logging.Formatter(
'%(asctime)s - %(thread)ld - %(threadName)s - %(name)s - %(funcName)s - %(levelname)s - %(message)s')
32 ch.setFormatter(formatter)
36 TEST_TITLE_OBJECT =
" object:\n" 40 CONFIG_SECTION =
"TasksStateUpdateService" 41 config = ConfigParser.RawConfigParser()
42 config.add_section(CONFIG_SECTION)
43 config.set(CONFIG_SECTION,
"clientTasksManager",
"TasksManager")
44 config.set(CONFIG_SECTION,
"serverHost",
"127.0.0.1")
45 config.set(CONFIG_SECTION,
"serverPort",
"5500")
46 config.set(CONFIG_SECTION,
"clientExecutionEnvironmentManager",
"ExecutionEnvironmentManager")
47 config.set(CONFIG_SECTION,
"checkStateInterval",
"10")
48 config.set(CONFIG_SECTION,
"checkStateTasks",
"20")
53 adminServerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
54 BaseServerManager.ADMIN_CONNECT_ENDPOINT)
56 serverConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
"TasksManager")
58 serverConnection2 = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
"ExecutionEnvironmentManager")
62 print TEST_TITLE + tsus.__class__.__name__ + TEST_TITLE_OBJECT, vars(tsus)
63 tsus.setName(tsus.__class__.__name__)
68 print "Stopped after" + str(TTL) +
" sec of run!"
The TasksStateUpdateService class, is a listener of tasks state updates from DRCE FO of cluster nodes...
Class hides routines of bulding connection objects.