VOL-3121 - Added filter argument to ports_state_update().
Change-Id: If39886bd5b103fa3dbcf4d6bffbde1cc497901b0
diff --git a/VERSION b/VERSION
index 73462a5..f225a78 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.5.1
+2.5.2
diff --git a/pyvoltha/adapters/kafka/core_proxy.py b/pyvoltha/adapters/kafka/core_proxy.py
index 5c6ab33..a756855 100644
--- a/pyvoltha/adapters/kafka/core_proxy.py
+++ b/pyvoltha/adapters/kafka/core_proxy.py
@@ -415,10 +415,13 @@
@inlineCallbacks
def ports_state_update(self,
device_id,
+ port_type_filter,
oper_status):
log.debug("ports_state_update", device_id=device_id, oper_status=oper_status)
id = ID()
id.id = device_id
+ t_filter = IntType()
+ t_filter.val = port_type_filter
o_status = IntType()
o_status.val = oper_status
@@ -431,8 +434,9 @@
to_topic=to_topic,
reply_topic=reply_topic,
device_id=id,
+ port_type_filter=t_filter,
oper_status=o_status)
- log.debug("ports_state_update_response", device_id=device_id, oper_status=oper_status, response=res)
+ log.debug("ports_state_update_response", device_id=device_id, port_type_filter=port_type_filter, oper_status=oper_status, response=res)
returnValue(res)
def port_removed(device_id, port):
diff --git a/requirements.txt b/requirements.txt
index e293cea..9b2d2cb 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -18,4 +18,4 @@
structlog==19.2.0
transitions==0.6.4
txaioetcd==0.3.0
-voltha-protos==3.4.0
+voltha-protos==3.4.1