launch_ems.py
No OneTemporary
Actions

Subscribers

None

File Metadata


	from queue import Queue
	import bmsinterface.bms_interf as bmsinterface
	import cms.cms_main as cmsinterf

	print("Start EMS ")

	shared_stream_cms_bms = Queue()

	bms_interf = bmsinterface.BMSInterface(shared_stream_cms_bms)
	cms = cmsinterf.ClusteringManagementSystem(shared_stream_cms_bms)

	bms_interf.start()
	cms.start()

	# Do infinite loop here for EMS job

	bms_interf.join()
	cms.join()