small fixes

Mellanox · Nov 26, 2024 · 13331d9 · 13331d9
1 parent d2dbf5e
commit 13331d9
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/plugins/fluentd_telemetry_plugin/src/schemas/set_conf.schema.json b/plugins/fluentd_telemetry_plugin/src/schemas/set_conf.schema.json
@@ -54,7 +54,12 @@
           },
           "message_tag_name": {
             "type": "string"
-          }
+          },
+          "timeout": {
+          "type": "integer",
+          "minimum": 1,
+          "err_message": "[telemetry-endpoint - timeout] attribute should be an integer greater than 0"
+        }
         },
         "required": [
           "host",

diff --git a/plugins/fluentd_telemetry_plugin/src/streamer.py b/plugins/fluentd_telemetry_plugin/src/streamer.py
@@ -51,6 +51,9 @@ def __init__(self, conf_parser):
         self.telem_parser = TelemetryParser(self.config_parser, self.streaming_metrics_mgr,
                                             self.last_streamed_data_sample_per_endpoint,
                                             self.attributes_mngr)
+        self.init_streaming_attributes()
+
+    def init_streaming_attributes(self):
         self.attributes_mngr.init_streaming_attributes(self.telem_parser,
                                                        self.ufm_telemetry_endpoints, self.config_parser)