o õæh!ã@s\ddlZddlmZmZerddlmZddlmZGdd„dejƒZ Gdd „d ejƒZ dS) éN)Ú TYPE_CHECKINGÚAnyé)ÚSpan)ÚTracec@speZdZdZejddd„ƒZejddd „ƒZejdd d „ƒZejddd„ƒZ ejddd„ƒZ ejddd„ƒZ dS)ÚTracingProcessora«Interface for processing and monitoring traces and spans in the OpenAI Agents system. This abstract class defines the interface that all tracing processors must implement. Processors receive notifications when traces and spans start and end, allowing them to collect, process, and export tracing data. Example: ```python class CustomProcessor(TracingProcessor): def __init__(self): self.active_traces = {} self.active_spans = {} def on_trace_start(self, trace): self.active_traces[trace.trace_id] = trace def on_trace_end(self, trace): # Process completed trace del self.active_traces[trace.trace_id] def on_span_start(self, span): self.active_spans[span.span_id] = span def on_span_end(self, span): # Process completed span del self.active_spans[span.span_id] def shutdown(self): # Clean up resources self.active_traces.clear() self.active_spans.clear() def force_flush(self): # Force processing of any queued items pass ``` Notes: - All methods should be thread-safe - Methods should not block for long periods - Handle errors gracefully to prevent disrupting agent execution ÚtracerÚreturnNcCódS)aTCalled when a new trace begins execution. Args: trace: The trace that started. Contains workflow name and metadata. Notes: - Called synchronously on trace start - Should return quickly to avoid blocking execution - Any errors should be caught and handled internally N©©Úselfrr r úc/var/www/html/openai_agents/venv/lib/python3.10/site-packages/agents/tracing/processor_interface.pyÚon_trace_start5ó zTracingProcessor.on_trace_startcCr )aQCalled when a trace completes execution. Args: trace: The completed trace containing all spans and results. Notes: - Called synchronously when trace finishes - Good time to export/process the complete trace - Should handle cleanup of any trace-specific resources Nr r r r rÚ on_trace_endCrzTracingProcessor.on_trace_endÚspanú Span[Any]cCr )aXCalled when a new span begins execution. Args: span: The span that started. Contains operation details and context. Notes: - Called synchronously on span start - Should return quickly to avoid blocking execution - Spans are automatically nested under current trace/span Nr ©r rr r rÚ on_span_startQrzTracingProcessor.on_span_startcCr )a9Called when a span completes execution. Args: span: The completed span containing execution results. Notes: - Called synchronously when span finishes - Should not block or raise exceptions - Good time to export/process the individual span Nr rr r rÚ on_span_end_rzTracingProcessor.on_span_endcCr )zØCalled when the application stops to clean up resources. Should perform any necessary cleanup like: - Flushing queued traces/spans - Closing connections - Releasing resources Nr ©r r r rÚshutdownmó zTracingProcessor.shutdowncCr )aForces immediate processing of any queued traces/spans. Notes: - Should process all queued items before returning - Useful before shutdown or when immediate processing is needed - May block while processing completes Nr rr r rÚ force_flushxrzTracingProcessor.force_flush)rrr N)rrr N)r N) Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚabcÚabstractmethodrrrrrrr r r rr s+      rc@s,eZdZdZejdedddfdd„ƒZdS)ÚTracingExporterzPExports traces and spans. For example, could log them or send them to a backend.ÚitemszTrace | Span[Any]r NcCr )zcExports a list of traces and spans. Args: items: The items to export. Nr )r r"r r rÚexport‡szTracingExporter.export)rrrrrr Úlistr#r r r rr!„sr!) rÚtypingrrÚspansrÚtracesrÚABCrr!r r r rÚs  {