From 43066fd9901d97e444d94926d0bc45c220f32fed Mon Sep 17 00:00:00 2001 From: Gabriel Luiz Freitas Almeida Date: Fri, 23 May 2025 17:01:23 -0300 Subject: [PATCH] fix: Add deactivated state checks in TracingService methods (#8128) fix: add deactivated state checks in TracingService methods --- src/backend/base/langflow/services/tracing/service.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/backend/base/langflow/services/tracing/service.py b/src/backend/base/langflow/services/tracing/service.py index d1af2b4ad..03d00ca71 100644 --- a/src/backend/base/langflow/services/tracing/service.py +++ b/src/backend/base/langflow/services/tracing/service.py @@ -132,7 +132,7 @@ class TracingService(Service): trace_context.traces_queue.task_done() async def _start(self, trace_context: TraceContext) -> None: - if trace_context.running: + if trace_context.running or self.deactivated: return try: trace_context.running = True @@ -150,6 +150,8 @@ class TracingService(Service): ) def _initialize_langwatch_tracer(self, trace_context: TraceContext) -> None: + if self.deactivated: + return if ( "langwatch" not in trace_context.tracers or trace_context.tracers["langwatch"].trace_id != trace_context.run_id @@ -163,6 +165,8 @@ class TracingService(Service): ) def _initialize_langfuse_tracer(self, trace_context: TraceContext) -> None: + if self.deactivated: + return langfuse_tracer = _get_langfuse_tracer() trace_context.tracers["langfuse"] = langfuse_tracer( trace_name=trace_context.run_name, @@ -174,6 +178,8 @@ class TracingService(Service): ) def _initialize_arize_phoenix_tracer(self, trace_context: TraceContext) -> None: + if self.deactivated: + return arize_phoenix_tracer = _get_arize_phoenix_tracer() trace_context.tracers["arize_phoenix"] = arize_phoenix_tracer( trace_name=trace_context.run_name, @@ -183,6 +189,8 @@ class TracingService(Service): ) def _initialize_opik_tracer(self, trace_context: TraceContext) -> None: + if self.deactivated: + return opik_tracer = _get_opik_tracer() trace_context.tracers["opik"] = opik_tracer( trace_name=trace_context.run_name,