diff --git a/VERSION b/VERSION
index 5859406..3afe9ad 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.2.3
+2.2.4-dev0
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):