Merge "Added support for versioned notifications"

watcher/decision_engine/model/notification/base.py

@@ -19,8 +19,6 @@
 import abc
 import six
 
-from watcher.common import rpc
-
 
 @six.add_metaclass(abc.ABCMeta)
 class NotificationEndpoint(object):
@@ -38,10 +36,3 @@ class NotificationEndpoint(object):
     @property
     def cluster_data_model(self):
         return self.collector.cluster_data_model
-
-    @property
-    def notifier(self):
-        if self._notifier is None:
-            self._notifier = rpc.get_notifier('decision-engine')
-
-        return self._notifier

watcher/decision_engine/rpcapi.py

@@ -43,7 +43,7 @@ class DecisionEngineAPI(service.Service):
             raise exception.InvalidUuidOrName(name=audit_uuid)
 
         return self.conductor_client.call(
-            context.to_dict(), 'trigger_audit', audit_uuid=audit_uuid)
+            context, 'trigger_audit', audit_uuid=audit_uuid)
 
 
 class DecisionEngineAPIManager(object):