From 72dea5310e29f014e20ac1a05d5f53e077fe1882 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jo=C3=A3o=20Moura?= <joaomdmoura@gmail.com>
Date: Mon, 19 Feb 2024 22:48:14 -0300
Subject: [PATCH] Increasing timeout for telemetry

---
 src/crewai/telemtry/telemetry.py | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/crewai/telemtry/telemetry.py b/src/crewai/telemtry/telemetry.py
index 71259a726..3b4b22a60 100644
--- a/src/crewai/telemtry/telemetry.py
+++ b/src/crewai/telemtry/telemetry.py
@@ -41,10 +41,12 @@ class Telemetry:
         self.ready = False
         try:
             telemetry_endpoint = "http://telemetry.crewai.com:4318"
-            self.resource = Resource(attributes={SERVICE_NAME: "crewAI-telemetry"})
+            self.resource = Resource(
+                attributes={SERVICE_NAME: "crewAI-telemetry"},
+            )
             self.provider = TracerProvider(resource=self.resource)
             processor = BatchSpanProcessor(
-                OTLPSpanExporter(endpoint=f"{telemetry_endpoint}/v1/traces")
+                OTLPSpanExporter(endpoint=f"{telemetry_endpoint}/v1/traces", timeout=60)
             )
             self.provider.add_span_processor(processor)
             self.ready = True
@@ -53,7 +55,10 @@ class Telemetry:
 
     def set_tracer(self):
         if self.ready:
-            trace.set_tracer_provider(self.provider)
+            try:
+                trace.set_tracer_provider(self.provider)
+            except Exception:
+                self.ready = False
 
     def crew_creation(self, crew):
         """Records the creation of a crew."""