Read tracing API data lazily

rm-openai · rm-openai · commit 6168340dff28 · 2025-03-21T15:26:26.000-04:00
diff --git a/src/agents/tracing/processors.py b/src/agents/tracing/processors.py
@@ -5,6 +5,7 @@
 import random
 import threading
 import time
+from functools import cached_property
 from typing import Any
 
 import httpx
@@ -50,9 +51,9 @@ def __init__(
             base_delay: Base delay (in seconds) for the first backoff.
             max_delay: Maximum delay (in seconds) for backoff growth.
         """
-        self.api_key = api_key or os.environ.get("OPENAI_API_KEY")
-        self.organization = organization or os.environ.get("OPENAI_ORG_ID")
-        self.project = project or os.environ.get("OPENAI_PROJECT_ID")
+        self._api_key = api_key
+        self._organization = organization
+        self._project = project
         self.endpoint = endpoint
         self.max_retries = max_retries
         self.base_delay = base_delay
@@ -61,14 +62,30 @@ def __init__(
         # Keep a client open for connection pooling across multiple export calls
         self._client = httpx.Client(timeout=httpx.Timeout(timeout=60, connect=5.0))
 
+        self._lazy_read_complete = False
+
     def set_api_key(self, api_key: str):
         """Set the OpenAI API key for the exporter.
 
         Args:
             api_key: The OpenAI API key to use. This is the same key used by the OpenAI Python
                 client.
         """
-        self.api_key = api_key
+        # Reset the cached property
+        del self.api_key
+        self._api_key = api_key
+
+    @cached_property
+    def api_key(self):
+        return self._api_key or os.environ.get("OPENAI_API_KEY")
+
+    @cached_property
+    def organization(self):
+        return self._organization or os.environ.get("OPENAI_ORG_ID")
+
+    @cached_property
+    def project(self):
+        return self._project or os.environ.get("OPENAI_PROJECT_ID")
 
     def export(self, items: list[Trace | Span[Any]]) -> None:
         if not items:
