2020from agentlightning .types import LLM , AttemptedRollout , NamedResources , Rollout
2121
2222from ..common .network import get_free_port
23- from ..common .tracer import clear_agentops_init , clear_tracer_provider
23+ from ..common .tracer import clear_tracer_provider
2424from ..common .vllm import VLLM_AVAILABLE , RemoteOpenAIServer
2525
2626
@@ -46,6 +46,9 @@ def teardown_runner(runner: LitAgentRunner[Any]) -> None:
4646
4747@pytest .fixture (scope = "module" , autouse = True )
4848def setup_module ():
49+ # This must execute only once for this module.
50+ # Once agentops tracer is initialized, it cannot be reset,
51+ # otherwise it will never be rewired.
4952 clear_tracer_provider ()
5053 yield
5154
@@ -175,8 +178,6 @@ async def validation_rollout_async(self, task: str, resources: NamedResources, r
175178 assert response .choices , "Proxy should return at least one choice"
176179 return 0.5
177180
178- clear_tracer_provider ()
179- clear_agentops_init ()
180181 agent = ProxyAgent ()
181182 runner , store = await init_runner (agent )
182183
@@ -199,7 +200,7 @@ async def validation_rollout_async(self, task: str, resources: NamedResources, r
199200 )
200201
201202 def run_proxy_server (proxy : LLMProxy , event : MpEvent ):
202- clear_tracer_provider ()
203+ clear_tracer_provider () # clear once more before the proxy starts
203204 proxy .start ()
204205 event .set ()
205206 time .sleep (3600 ) # Keep the server running
0 commit comments