|
3 | 3 | from typing import TYPE_CHECKING |
4 | 4 | from threading import Lock |
5 | 5 |
|
6 | | -from agentex.lib.types.tracing import TracingProcessorConfig, AgentexTracingProcessorConfig |
| 6 | +from agentex.lib.types.tracing import TracingProcessorConfig |
7 | 7 | from agentex.lib.core.tracing.processors.sgp_tracing_processor import ( |
8 | 8 | SGPSyncTracingProcessor, |
9 | 9 | SGPAsyncTracingProcessor, |
@@ -73,22 +73,8 @@ def get_async_processors(self) -> list[AsyncTracingProcessor]: |
73 | 73 | add_tracing_processor_config = GLOBAL_TRACING_PROCESSOR_MANAGER.add_processor_config |
74 | 74 | set_tracing_processor_configs = GLOBAL_TRACING_PROCESSOR_MANAGER.set_processor_configs |
75 | 75 |
|
76 | | -# Lazy initialization to avoid circular imports |
77 | | -_default_initialized = False |
78 | | - |
79 | | -def _ensure_default_initialized(): |
80 | | - """Ensure default processor is initialized (lazy to avoid circular imports).""" |
81 | | - global _default_initialized |
82 | | - if not _default_initialized: |
83 | | - add_tracing_processor_config(AgentexTracingProcessorConfig()) |
84 | | - _default_initialized = True |
85 | | - |
86 | 76 | def get_sync_tracing_processors(): |
87 | | - """Get sync processors, initializing defaults if needed.""" |
88 | | - _ensure_default_initialized() |
89 | 77 | return GLOBAL_TRACING_PROCESSOR_MANAGER.get_sync_processors() |
90 | 78 |
|
91 | 79 | def get_async_tracing_processors(): |
92 | | - """Get async processors, initializing defaults if needed.""" |
93 | | - _ensure_default_initialized() |
94 | 80 | return GLOBAL_TRACING_PROCESSOR_MANAGER.get_async_processors() |
0 commit comments