planetstack/openstack/backend.py

   1 import threading
   2 from openstack.observer import OpenStackObserver
   3 from openstack.event_manager import EventListener
   4
   5 class Backend:
   6
   7     def run(self):
   8         # start the openstack observer
   9         observer = OpenStackObserver()
  10         observer_thread = threading.Thread(target=observer.run)
  11         observer_thread.start()
  12
  13         # start event listene
  14         event_manager = EventListener(wake_up=observer.wake_up)
  15         event_manager_thread = threading.Thread(target=event_manager.run)
  16         event_manager_thread.start()
  17