4040 reason = "GOOGLE_API_KEY not set" ,
4141)
4242
43+
4344def _run_agent (
4445 script : str ,
4546 otlp_http_port : int ,
@@ -72,10 +73,12 @@ def _run_agent(
7273
7374@contextlib .contextmanager
7475def _agentcore_server (otlp_http_port : int , session_name : str , extra_env : dict | None = None ):
75- env = {** os .environ ,
76- "OTEL_EXPORTER_OTLP_ENDPOINT" : f"http://127.0.0.1:{ otlp_http_port } " ,
77- "OTEL_RESOURCE_ATTRIBUTES" : f"agentevals.eval_set_id=e2e-test,agentevals.session_name={ session_name } " ,
78- ** (extra_env or {})}
76+ env = {
77+ ** os .environ ,
78+ "OTEL_EXPORTER_OTLP_ENDPOINT" : f"http://127.0.0.1:{ otlp_http_port } " ,
79+ "OTEL_RESOURCE_ATTRIBUTES" : f"agentevals.eval_set_id=e2e-test,agentevals.session_name={ session_name } " ,
80+ ** (extra_env or {}),
81+ }
7982 proc = subprocess .Popen ([sys .executable , os .path .join (REPO_ROOT , _AGENTCORE_SCRIPT )], env = env , cwd = REPO_ROOT )
8083 try :
8184 for _ in range (20 ):
@@ -406,7 +409,9 @@ def test_session_created_spans_only(self, live_servers):
406409 main_port , otlp_http_port , mgr = live_servers
407410 session_name = "e2e-agentcore"
408411 with _agentcore_server (otlp_http_port , session_name , extra_env = _AGENTCORE_ENV ):
409- r = httpx .post (f"http://127.0.0.1:{ _AGENTCORE_PORT } /invocations" , json = {"prompt" : "Roll a 20-sided die" }, timeout = 60 )
412+ r = httpx .post (
413+ f"http://127.0.0.1:{ _AGENTCORE_PORT } /invocations" , json = {"prompt" : "Roll a 20-sided die" }, timeout = 60
414+ )
410415 assert r .status_code == 200
411416 wait_for_session_complete_sync (mgr , session_name , timeout = 60 )
412417 s = mgr .sessions [session_name ]
@@ -416,7 +421,9 @@ def test_invocations_extracted(self, live_servers):
416421 main_port , otlp_http_port , mgr = live_servers
417422 session_name = "e2e-agentcore-inv"
418423 with _agentcore_server (otlp_http_port , session_name , extra_env = _AGENTCORE_ENV ):
419- r = httpx .post (f"http://127.0.0.1:{ _AGENTCORE_PORT } /invocations" , json = {"prompt" : "Is 17 prime?" }, timeout = 60 )
424+ r = httpx .post (
425+ f"http://127.0.0.1:{ _AGENTCORE_PORT } /invocations" , json = {"prompt" : "Is 17 prime?" }, timeout = 60
426+ )
420427 assert r .status_code == 200
421428 wait_for_session_complete_sync (mgr , session_name , timeout = 60 )
422429 assert len (mgr .sessions [session_name ].invocations ) > 0
0 commit comments