refactor: use set_env_from_globals in tracers

Author: italojohnny

src/backend/base/langflow/services/tracing/arize_phoenix.py

@@ -20,6 +20,7 @@
 from langflow.schema.data import Data
 from langflow.schema.message import Message
 from langflow.services.tracing.base import BaseTracer
+from langflow.services.tracing.utils import set_env_from_globals
 
 if TYPE_CHECKING:
     from collections.abc import Sequence
@@ -70,8 +71,7 @@ def __init__(
         self.session_id = session_id
 
         for key in ArizePhoenixTracer.get_required_variable_names():
-            if key in global_vars:
-                os.environ[key] = global_vars.get(key)
+            set_env_from_globals(key, global_vars)
 
         try:
             self._ready = self.setup_arize_phoenix()

src/backend/base/langflow/services/tracing/langfuse.py

@@ -9,6 +9,7 @@
 from typing_extensions import override
 
 from langflow.services.tracing.base import BaseTracer
+from langflow.services.tracing.utils import set_env_from_globals
 
 if TYPE_CHECKING:
     from collections.abc import Sequence
@@ -51,8 +52,7 @@ def __init__(
         self.spans: dict = OrderedDict()  # spans that are not ended
 
         for key in LangFuseTracer.get_required_variable_names():
-            if key in global_vars:
-                os.environ[key] = global_vars.get(key)
+            set_env_from_globals(key, global_vars)
 
         config = self._get_config()
         self._ready: bool = self.setup_langfuse(config) if config else False

src/backend/base/langflow/services/tracing/langsmith.py

@@ -11,6 +11,7 @@
 
 from langflow.schema.data import Data
 from langflow.services.tracing.base import BaseTracer
+from langflow.services.tracing.utils import set_env_from_globals
 
 if TYPE_CHECKING:
     from collections.abc import Sequence
@@ -34,8 +35,7 @@ def __init__(
     ):
         try:
             for key in LangSmithTracer.get_required_variable_names():
-                if key in global_vars:
-                    os.environ[key] = global_vars.get(key)
+                set_env_from_globals(key, global_vars)
 
             self._ready = self.setup_langsmith()
             if not self._ready:

src/backend/base/langflow/services/tracing/langwatch.py

@@ -9,6 +9,7 @@
 
 from langflow.schema.data import Data
 from langflow.services.tracing.base import BaseTracer
+from langflow.services.tracing.utils import set_env_from_globals
 
 if TYPE_CHECKING:
     from collections.abc import Sequence
@@ -38,8 +39,7 @@ def __init__(
         self.flow_id = trace_name.split(" - ")[-1]
 
         for key in LangWatchTracer.get_required_variable_names():
-            if key in global_vars:
-                os.environ[key] = global_vars.get(key)
+            set_env_from_globals(key, global_vars)
 
         try:
             self._ready: bool = self.setup_langwatch()

src/backend/base/langflow/services/tracing/opik.py

@@ -12,6 +12,7 @@
 from langflow.schema.data import Data
 from langflow.schema.message import Message
 from langflow.services.tracing.base import BaseTracer
+from langflow.services.tracing.utils import set_env_from_globals
 
 if TYPE_CHECKING:
     from collections.abc import Sequence
@@ -59,8 +60,7 @@ def __init__(
         self.spans: dict = {}
 
         for key in OpikTracer.get_required_variable_names():
-            if key in global_vars:
-                os.environ[key] = global_vars.get(key)
+            set_env_from_globals(key, global_vars)
 
         config = self._get_config()
         self._ready: bool = self._setup_opik(config, trace_id) if config else False