feat(observability): remove unnecessary logging statements to enhance clarity

Author: vprashrex

backend/app/core/langfuse/langfuse.py

@@ -321,7 +321,6 @@ def wrapper(
             completion_config: NativeCompletionConfig, query: QueryParams, **kwargs
         ):
             if not credentials:
-                logger.info("[observe_llm_execution] No credentials - skipping tracing")
                 return func(completion_config, query, **kwargs)
 
             try:

backend/app/core/telemetry/tracing.py

@@ -164,11 +164,6 @@ def setup_telemetry(service_name: str | None = None) -> None:
     except Exception:
         logger.exception("[setup_telemetry] Failed to instrument botocore")
 
-    logger.debug(
-        "[setup_telemetry] OpenTelemetry initialized (service=%s, sink=Sentry)",
-        service_name or settings.OTEL_SERVICE_NAME,
-    )
-
 
 def flush_telemetry(timeout_millis: int = 10000) -> None:
     """Force-flush OTel spans into Sentry, then flush Sentry's transport.
@@ -215,4 +210,3 @@ def instrument_app(app: FastAPI) -> None:
         excluded_urls=excluded_urls,
         exclude_spans=FASTAPI_EXCLUDED_SPANS,
     )
-    logger.debug("[instrument_app] FastAPI instrumented with OpenTelemetry")

backend/app/services/llm/providers/google_aistudio.py

@@ -169,10 +169,6 @@ def _execute_stt(
         else:
             merged_instruction = f"{lang_instruction}. {forced_transcription_text}"
 
-        logger.info(
-            f"[GoogleAIProvider._execute_stt] Built instruction | instruction_len={len(merged_instruction)} | input_language={input_language} | output_language={output_language}"
-        )
-
         # Materialize the AudioRef to a temp file so the genai SDK can upload it.
         with resolved_input.to_path() as audio_path:
             gemini_file = self.client.files.upload(file=audio_path)

backend/app/tests/test_utils.py

@@ -427,26 +427,6 @@ class TestSendCallbackLogging:
         "metadata": {"job_id": "j1", "request_metadata": {"ref": "abc"}},
     }
 
-    @patch("app.utils.validate_callback_url")
-    @patch("requests.Session")
-    def test_success_logs_everything_except_user_data(
-        self, mock_session_cls, mock_validate, caplog: pytest.LogCaptureFixture
-    ) -> None:
-        mock_session = MagicMock()
-        mock_session.post.return_value = MagicMock(status_code=200)
-        mock_session_cls.return_value.__enter__.return_value = mock_session
-
-        with caplog.at_level("INFO", logger="app.utils"):
-            assert send_callback("https://api.example.com/hook", self._payload)
-
-        line = next(
-            r.getMessage() for r in caplog.records if "Callback sent" in r.getMessage()
-        )
-        assert "url=https://api.example.com/hook" in line
-        assert "status=200" in line
-        assert "'request_metadata': {'ref': 'abc'}" in line
-        assert "model answer for the user" not in line
-
     @patch("app.utils.validate_callback_url")
     @patch("requests.Session")
     def test_failure_logs_status_and_payload_without_user_data(

backend/app/utils.py

@@ -618,12 +618,6 @@ def send_callback(
             span.set_attribute("callback.response.status_code", response.status_code)
 
             response.raise_for_status()
-
-            logger.info(
-                f"[send_callback] Callback sent | url={callback_url} | status={response.status_code} "
-                f"| duration_ms={(time.perf_counter() - started_at) * 1000:.2f} "
-                f"| bytes={len(raw_body)} | payload={log_payload}"
-            )
             return True
 
     except requests.RequestException as e: