From 161c4a68566547a069848301c981ff92d9c012cf Mon Sep 17 00:00:00 2001 From: Gui Vieira Date: Mon, 15 Jul 2024 17:43:57 -0300 Subject: [PATCH] Fix crew creation telemetry (#939) * Fix crew creation telemetry * Remove task index --- src/crewai/telemetry/telemetry.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/crewai/telemetry/telemetry.py b/src/crewai/telemetry/telemetry.py index 552c22edd4..534b663bf7 100644 --- a/src/crewai/telemetry/telemetry.py +++ b/src/crewai/telemetry/telemetry.py @@ -171,7 +171,6 @@ def task_started(self, crew: Crew, task: Task) -> Span | None: created_span = tracer.start_span("Task Created") self._add_attribute(created_span, "crew_id", str(crew.id)) - self._add_attribute(created_span, "task_index", crew.tasks.index(task)) self._add_attribute(created_span, "task_id", str(task.id)) if crew.share_crew: @@ -188,7 +187,6 @@ def task_started(self, crew: Crew, task: Task) -> Span | None: span = tracer.start_span("Task Execution") self._add_attribute(span, "crew_id", str(crew.id)) - self._add_attribute(span, "task_index", crew.tasks.index(task)) self._add_attribute(span, "task_id", str(task.id)) if crew.share_crew: @@ -284,10 +282,10 @@ def crew_execution_span(self, crew: Crew, inputs: dict[str, Any] | None): """Records the complete execution of a crew. This is only collected if the user has opted-in to share the crew. """ + self.crew_creation(crew, inputs) + if (self.ready) and (crew.share_crew): try: - self.crew_creation(crew, inputs) - tracer = trace.get_tracer("crewai.telemetry") span = tracer.start_span("Crew Execution") self._add_attribute(