commit 729e3cb20801a063d13a46f3d346864a1272a124
author Mahir Gunyel <mahir.gunyel@netsia.com> Wed Oct 16 16:58:45 2019 -0700
committer Mahir Gunyel <mahir.gunyel@netsia.com> Thu Oct 17 09:27:21 2019 -0700
tree fea6406849b1960c756fc67dadd9e073ebc273e9
parent 994b0f0116b20cd8be84ffa312d25678106a8cc8

VOL-2103 - Device reason update modifications

device_reason_update api is added to core_proxy.

Change-Id: I7a0271c9b1b8d0eda0058be39673b4780326f266

VERSION

diff --git a/VERSION b/VERSION
index 5859406..3afe9ad 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.2.3
+2.2.4-dev0

pyvoltha/adapters/kafka/core_proxy.py

diff --git a/pyvoltha/adapters/kafka/core_proxy.py b/pyvoltha/adapters/kafka/core_proxy.py
index 01ea362..38a746b 100644
--- a/pyvoltha/adapters/kafka/core_proxy.py
+++ b/pyvoltha/adapters/kafka/core_proxy.py
@@ -454,7 +454,25 @@
                                 port=p,
                                 packet=pac)
         returnValue(res)
-        
+
+    @ContainerProxy.wrap_request(None)
+    @inlineCallbacks
+    def device_reason_update(self, device_id, reason):
+        id = ID()
+        id.id = device_id
+        rsn = StrType()
+        rsn.val = reason
+        to_topic = self.get_core_topic(device_id)
+        reply_topic = self.get_adapter_topic()
+
+        res = yield self.invoke(rpc="DeviceReasonUpdate",
+                                to_topic=to_topic,
+                                reply_topic=reply_topic,
+                                device_id=id,
+                                device_reason=rsn)
+
+        returnValue(res)
+                
     # ~~~~~~~~~~~~~~~~~~~ Handle event submissions ~~~~~~~~~~~~~~~~~~~~~
 
     def filter_alarm(self, device_id, alarm_event):