From fec719bdc09bfc061e835b2ff21ef46fc0d24c81 Mon Sep 17 00:00:00 2001 From: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> Date: Tue, 3 Jun 2025 21:22:17 +0000 Subject: [PATCH] Fix mypy type-checker errors MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Add explicit bool type annotation to _initialized field - Fix return value in task_started method to not return _safe_telemetry_operation result - Simplify initialization logic to set _initialized once in __init__ Co-Authored-By: João --- src/crewai/telemetry/telemetry.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/crewai/telemetry/telemetry.py b/src/crewai/telemetry/telemetry.py index 9fce45b13..f75809a02 100644 --- a/src/crewai/telemetry/telemetry.py +++ b/src/crewai/telemetry/telemetry.py @@ -77,14 +77,14 @@ class Telemetry: return cls._instance def __init__(self) -> None: - if self._initialized: + if hasattr(self, '_initialized') and self._initialized: return self.ready: bool = False self.trace_set: bool = False + self._initialized: bool = True if self._is_telemetry_disabled(): - self._initialized = True return try: @@ -110,8 +110,6 @@ class Telemetry: ): raise # Re-raise the exception to not interfere with system signals self.ready = False - finally: - self._initialized = True def _is_telemetry_disabled(self) -> bool: """Check if telemetry should be disabled based on environment variables.""" @@ -435,7 +433,8 @@ class Telemetry: return span - return self._safe_telemetry_operation(operation) + self._safe_telemetry_operation(operation) + return None def task_ended(self, span: Span, task: Task, crew: Crew): """Records the completion of a task execution in a crew. @@ -785,7 +784,8 @@ class Telemetry: return span if crew.share_crew: - return self._safe_telemetry_operation(operation) + self._safe_telemetry_operation(operation) + return operation() return None def end_crew(self, crew, final_string_output):