fix

Author: michalkulakowski

src/audio/speech_to_text/stt_calculator.cc

@@ -197,17 +197,17 @@ class SttCalculator : public CalculatorBase {
     }
 
     absl::Status Close(CalculatorContext* cc) final {
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "SpeechToTextCalculator [Node: {} ] Close", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(stt_calculator_logger, "SpeechToTextCalculator [Node: {} ] Close", cc->NodeName());
         return absl::OkStatus();
     }
 
     absl::Status Open(CalculatorContext* cc) final {
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "SpeechToTextCalculator  [Node: {}] Open start", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(stt_calculator_logger, "SpeechToTextCalculator  [Node: {}] Open start", cc->NodeName());
         return absl::OkStatus();
     }
 
     absl::Status Process(CalculatorContext* cc) final {
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "SpeechToTextCalculator  [Node: {}] Process start", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(stt_calculator_logger, "SpeechToTextCalculator  [Node: {}] Process start", cc->NodeName());
 
         SttServableMap pipelinesMap = cc->InputSidePackets().Tag(STT_SESSION_SIDE_PACKET_TAG).Get<SttServableMap>();
         auto it = pipelinesMap.find(cc->NodeName());
@@ -252,7 +252,7 @@ class SttCalculator : public CalculatorBase {
         }
 
         cc->Outputs().Tag(OUTPUT_TAG_NAME).Add(output.release(), cc->InputTimestamp());
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "SpeechToTextCalculator  [Node: {}] Process end", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(stt_calculator_logger, "SpeechToTextCalculator  [Node: {}] Process end", cc->NodeName());
 
         return absl::OkStatus();
     }

src/audio/text_to_speech/tts_calculator.cc

@@ -72,17 +72,17 @@ class TtsCalculator : public CalculatorBase {
     }
 
     absl::Status Close(CalculatorContext* cc) final {
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "TtsCalculator [Node: {} ] Close", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(tts_calculator_logger, "TtsCalculator [Node: {} ] Close", cc->NodeName());
         return absl::OkStatus();
     }
 
     absl::Status Open(CalculatorContext* cc) final {
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "TtsCalculator  [Node: {}] Open start", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(tts_calculator_logger, "TtsCalculator  [Node: {}] Open start", cc->NodeName());
         return absl::OkStatus();
     }
 
     absl::Status Process(CalculatorContext* cc) final {
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "TtsCalculator  [Node: {}] Process start", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(tts_calculator_logger, "TtsCalculator  [Node: {}] Process start", cc->NodeName());
 
         TtsServableMap pipelinesMap = cc->InputSidePackets().Tag(TTS_SESSION_SIDE_PACKET_TAG).Get<TtsServableMap>();
         auto it = pipelinesMap.find(cc->NodeName());
@@ -142,7 +142,7 @@ class TtsCalculator : public CalculatorBase {
         }
 
         cc->Outputs().Tag(OUTPUT_TAG_NAME).Add(output.release(), cc->InputTimestamp());
-        SPDLOG_LOGGER_DEBUG(llm_calculator_logger, "TtsCalculator  [Node: {}] Process end", cc->NodeName());
+        SPDLOG_LOGGER_DEBUG(tts_calculator_logger, "TtsCalculator  [Node: {}] Process end", cc->NodeName());
 
         return absl::OkStatus();
     }

src/logging.cpp

@@ -33,6 +33,8 @@ std::shared_ptr<spdlog::logger> capi_logger = std::make_shared<spdlog::logger>("
 std::shared_ptr<spdlog::logger> mediapipe_logger = std::make_shared<spdlog::logger>("mediapipe");
 std::shared_ptr<spdlog::logger> llm_executor_logger = std::make_shared<spdlog::logger>("llm_executor");
 std::shared_ptr<spdlog::logger> llm_calculator_logger = std::make_shared<spdlog::logger>("llm_calculator");
+std::shared_ptr<spdlog::logger> stt_calculator_logger = std::make_shared<spdlog::logger>("stt_calculator");
+std::shared_ptr<spdlog::logger> tts_calculator_logger = std::make_shared<spdlog::logger>("tts_calculator");
 std::shared_ptr<spdlog::logger> embeddings_calculator_logger = std::make_shared<spdlog::logger>("embeddings_calculator");
 std::shared_ptr<spdlog::logger> rerank_calculator_logger = std::make_shared<spdlog::logger>("rerank_calculator");
 #endif
@@ -74,6 +76,8 @@ static void register_loggers(const std::string& log_level, std::vector<spdlog::s
     mediapipe_logger->set_pattern(default_pattern);
     llm_executor_logger->set_pattern(default_pattern);
     llm_calculator_logger->set_pattern(default_pattern);
+    stt_calculator_logger->set_pattern(default_pattern);
+    tts_calculator_logger->set_pattern(default_pattern);
     rerank_calculator_logger->set_pattern(default_pattern);
     embeddings_calculator_logger->set_pattern(default_pattern);
 #endif
@@ -92,6 +96,8 @@ static void register_loggers(const std::string& log_level, std::vector<spdlog::s
         mediapipe_logger->sinks().push_back(sink);
         llm_executor_logger->sinks().push_back(sink);
         llm_calculator_logger->sinks().push_back(sink);
+        stt_calculator_logger->sinks().push_back(sink);
+        tts_calculator_logger->sinks().push_back(sink);
         rerank_calculator_logger->sinks().push_back(sink);
         embeddings_calculator_logger->sinks().push_back(sink);
 #endif
@@ -111,6 +117,8 @@ static void register_loggers(const std::string& log_level, std::vector<spdlog::s
     set_log_level(log_level, mediapipe_logger);
     set_log_level(log_level, llm_executor_logger);
     set_log_level(log_level, llm_calculator_logger);
+    set_log_level(log_level, stt_calculator_logger);
+    set_log_level(log_level, tts_calculator_logger);
     set_log_level(log_level, rerank_calculator_logger);
     set_log_level(log_level, embeddings_calculator_logger);
 #endif

src/logging.hpp

@@ -36,6 +36,8 @@ extern std::shared_ptr<spdlog::logger> capi_logger;
 extern std::shared_ptr<spdlog::logger> mediapipe_logger;
 extern std::shared_ptr<spdlog::logger> llm_executor_logger;
 extern std::shared_ptr<spdlog::logger> llm_calculator_logger;
+extern std::shared_ptr<spdlog::logger> stt_calculator_logger;
+extern std::shared_ptr<spdlog::logger> tts_calculator_logger;
 extern std::shared_ptr<spdlog::logger> embeddings_calculator_logger;
 extern std::shared_ptr<spdlog::logger> rerank_calculator_logger;
 #endif