commit 7f9bb1a2457572b4017ea4d541b236f485233251
author khenaidoo <knursimu@ciena.com> Thu Nov 29 17:15:01 2018 -0500
committer khenaidoo <knursimu@ciena.com> Thu Nov 29 17:15:01 2018 -0500
tree 2e6e2eb983f5903663429cffbff8fcc9ac979030
parent 4c1a5bf5e314fd4d455315a5145b2b5b5c08fbbd

Fix missing inlinecallbacks for packet-in

Change-Id: I53660c1d0a53669f12029553b6b850aa52267396

python/adapters/kafka/core_proxy.py

diff --git a/python/adapters/kafka/core_proxy.py b/python/adapters/kafka/core_proxy.py
index 47f6a61..fa9544b 100644
--- a/python/adapters/kafka/core_proxy.py
+++ b/python/adapters/kafka/core_proxy.py
@@ -323,8 +323,10 @@
     def image_download_deleted(img_dnld):
         raise NotImplementedError()
 
+    @ContainerProxy.wrap_request(None)
+    @inlineCallbacks
     def send_packet_in(self, device_id, port, packet):
-        log.debug("send_packet_in")
+        log.debug("send_packet_in", device_id=device_id)
         proto_id = ID()
         proto_id.id = device_id
         p = IntType()