X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=planetstack%2Fopenstack_observer%2Fbackend.py;h=fe623ca32fc4751ecba757c65beed432be7bdc7c;hb=f0145bb21a3d824404511b91c25d3d5468de2c43;hp=293a32566d5cd6a0cce46d8ab927709f6b7092ce;hpb=a358f0fb280d3da6938575be3d9c5d4a4a7e3f7a;p=plstackapi.git diff --git a/planetstack/openstack_observer/backend.py b/planetstack/openstack_observer/backend.py index 293a325..fe623ca 100644 --- a/planetstack/openstack_observer/backend.py +++ b/planetstack/openstack_observer/backend.py @@ -3,22 +3,24 @@ import time from observer.event_loop import PlanetStackObserver from observer.event_manager import EventListener from util.logger import Logger, logging +from model_policy import run_policy logger = Logger(level=logging.INFO) class Backend: def run(self): - try: # start the openstack observer observer = PlanetStackObserver() observer_thread = threading.Thread(target=observer.run) observer_thread.start() + # start model policies thread + model_policy_thread = threading.Thread(target=run_policy) + model_policy_thread.start() + # start event listene event_manager = EventListener(wake_up=observer.wake_up) event_manager_thread = threading.Thread(target=event_manager.run) event_manager_thread.start() - except: - logger.log_exc("Exception in child thread")