Fixed func params

Telecominfraproject · Dec 10, 2024 · 7d1588c · 7d1588c
1 parent 2405379
commit 7d1588c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/utils/kafka_producer/src/consumer.py b/utils/kafka_producer/src/consumer.py
@@ -117,7 +117,7 @@ def get_single_msg(self, timeout_ms: int = 12000):
 
         return None
 
-    def get_msg_by_substring(self, substring: int):
+    def get_msg_by_substring(self, substring: int, uuid_val: int, timeout_ms: int = 12000):
         res_uuid = uuid.UUID(int=uuid_val)
 
         assert self.is_connected(),\