Skip to content

Commit

Permalink
fix comments
Browse files Browse the repository at this point in the history
  • Loading branch information
Miryam-Schwartz committed Nov 17, 2024
1 parent 2913a91 commit 7fd40b3
Showing 1 changed file with 0 additions and 18 deletions.
18 changes: 0 additions & 18 deletions plugins/fluentd_telemetry_plugin/src/streamer.py
Original file line number Diff line number Diff line change
Expand Up @@ -267,21 +267,3 @@ def clear_cached_streaming_data(self):
self.last_streamed_data_sample_timestamp = self._fluent_sender = None
self.last_streamed_data_sample_per_endpoint.clear()
self.streaming_metrics_mgr = MonitorStreamingMgr()

if __name__ == "__main__":
# init app config parser & load config files
config_parser = UFMTelemetryStreamingConfigParser()

# init logs configs
logs_file_name = config_parser.get_logs_file_name()
logs_level = config_parser.get_logs_level()
max_log_file_size = config_parser.get_log_file_max_size()
log_file_backup_count = config_parser.get_log_file_backup_count()
Logger.init_logs_config(logs_file_name, logs_level, max_log_file_size, log_file_backup_count)

telemetry_streaming = UFMTelemetryStreaming(config_parser)

# streaming_scheduler = StreamingScheduler.getInstance()
# streaming_scheduler.start_streaming(telemetry_streaming.stream_data, telemetry_streaming.streaming_interval)

# telemetry_streaming.stream_data()

0 comments on commit 7fd40b3

Please sign in to comment.