2 HCE project, Python bindings, Distributed Tasks Manager application. 3 ExecutionEnvironmentManager 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/ 27 if __name__ ==
"__main__":
28 logger = logging.getLogger()
30 ch = logging.StreamHandler(sys.stdout)
31 ch.setLevel(logging.DEBUG)
32 formatter = logging.Formatter(
'%(asctime)s - %(thread)ld - %(threadName)s - %(name)s - %(funcName)s - %(levelname)s - %(message)s')
33 ch.setFormatter(formatter)
36 if __name__ ==
"__main__":
38 TEST_TITLE_OBJECT =
" object:\n" 42 CONFIG_SECTION =
"ExecutionEnvironmentManager" 43 config = ConfigParser.RawConfigParser()
44 config.add_section(CONFIG_SECTION)
45 config.set(CONFIG_SECTION,
"server", CONFIG_SECTION)
46 config.set(CONFIG_SECTION,
"clientTasksManager",
"TasksManager")
47 config.set(CONFIG_SECTION,
"clientTasksManagerData",
"TasksManagerData")
48 config.set(CONFIG_SECTION,
"DRCEHost",
"localhost")
49 config.set(CONFIG_SECTION,
"DRCEPort",
"5557")
50 config.set(CONFIG_SECTION,
"DRCETimeout",
"1000")
51 config.set(CONFIG_SECTION,
"HCENodeAdminTimeout",
"1000")
59 adminServerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
60 BaseServerManager.ADMIN_CONNECT_ENDPOINT)
62 tasksManagerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
"TasksManager")
64 tasksManagerDataConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
"TasksManagerData")
71 print TEST_TITLE + eem.__class__.__name__ + TEST_TITLE_OBJECT, vars(eem)
73 eem.setName(eem.__class__.__name__)
79 event = eventBuilder.build(DTM_CONSTS.EVENT_TYPES.EXECUTE_TASK, executeTask)
80 eem.onExecuteTask(event)
81 print "ExecuteTask event sent" 87 print "Stopped after" + str(TTL) +
" sec of run!"
ExecuteTask event object, to set task to execute on EE.
Class hides routines of bulding connection objects.