异步语法 | dextermayhewjd

Python 原生异步语法；async def 与异步生成器定义分开计数。

固定源码版本：2f2318653f6f794dddd321eff7c9d4b7b174643f。本表共 747 条静态出现记录；不是运行次数。

同一个直接 API 表达式只记为 api_call 或 api_reference 中的一类。实例候选不计入直接原生 API 总数。

ID	位置 / 快照	所属符号	种类	API / 语法	来源判定	源码行
occ-000006	examples/coding_agent_rl/generate.py:96 · 快照	<module>	async_generator_def	boot_agent_sandbox	python_ast	async def boot_agent_sandbox(image: str, instance_id: str) -> AsyncIterator[E2BSandbox]:
occ-000008	examples/coding_agent_rl/generate.py:108 · 快照	boot_agent_sandbox	async_with	async with	python_ast	async with _BOOT_SEM:
occ-000009	examples/coding_agent_rl/generate.py:109 · 快照	boot_agent_sandbox	await	await	python_ast	await cand.aenter()
occ-000011	examples/coding_agent_rl/generate.py:111 · 快照	boot_agent_sandbox	await	await	python_ast	await HARNESS_CLS().install_cli(cand)
occ-000012	examples/coding_agent_rl/generate.py:113 · 快照	boot_agent_sandbox	await	await	python_ast	await cand.aexit(None, None, None)
occ-000014	examples/coding_agent_rl/generate.py:127 · 快照	boot_agent_sandbox	await	await	python_ast	await asyncio.sleep(1 + attempt + random.random())
occ-000016	examples/coding_agent_rl/generate.py:132 · 快照	boot_agent_sandbox	async_yield	yield in async generator	python_ast	yield sb
occ-000017	examples/coding_agent_rl/generate.py:134 · 快照	boot_agent_sandbox	await	await	python_ast	await sb.aexit(None, None, None)
occ-000019	examples/coding_agent_rl/generate.py:182 · 快照	<module>	async_def	generate	python_ast	async def generate(args, base_sample: Sample, sampling_params: dict[str, Any], evaluation: bool = False):
occ-000020	examples/coding_agent_rl/generate.py:202 · 快照	generate	async_with	async with	python_ast	async with asyncio.timeout(CONFIG.rollout_guard_sec):
occ-000022	examples/coding_agent_rl/generate.py:203 · 快照	generate	async_with	async with	python_ast	async with boot_agent_sandbox(md[“image”], instance_id) as sb:
occ-000023	examples/coding_agent_rl/generate.py:204 · 快照	generate	await	await	python_ast	await swe.prepare_workspace(sb, md[“workdir”], md)
occ-000024	examples/coding_agent_rl/generate.py:205 · 快照	generate	await	await	python_ast	agent_exit_code = await HARNESS_CLS().run(
occ-000025	examples/coding_agent_rl/generate.py:213 · 快照	generate	await	await	python_ast	diff_text = await swe.git_diff(sb, md[“workdir”])
occ-000026	examples/coding_agent_rl/generate.py:215 · 快照	generate	await	await	python_ast	reward, applied_cleanly = await swe.run_evaluation(
occ-000027	examples/coding_agent_rl/generate.py:237 · 快照	generate	await	await	python_ast	samples = await state.adapter.finish_session(
occ-000029	examples/coding_agent_rl/generate.py:282 · 快照	generate	await	await	python_ast	await state.adapter.drop_session(session_id, wait_timeout=30) # cleanup only, idempotent
occ-000030	examples/coding_agent_rl/generate.py:283 · 快照	generate	await	await	python_ast	await asyncio.sleep(10)
occ-000071	examples/coding_agent_rl/swe.py:177 · 快照	<module>	async_def	prepare_workspace	python_ast	async def prepare_workspace(sb: Sandbox, workdir: str, md: dict) -> None:
occ-000072	examples/coding_agent_rl/swe.py:185 · 快照	prepare_workspace	await	await	python_ast	await agent_sandbox.ensure_agent_user(sb, workdir)
occ-000076	examples/coding_agent_rl/swe.py:190 · 快照	prepare_workspace	await	await	python_ast	await apply_before_repo_set_cmd(sb, workdir, swepro)
occ-000078	examples/coding_agent_rl/swe.py:193 · 快照	prepare_workspace	await	await	python_ast	await apply_pre_commands(sb, workdir, pre_commands)
occ-000079	examples/coding_agent_rl/swe.py:194 · 快照	prepare_workspace	await	await	python_ast	await sb.write_file(
occ-000081	examples/coding_agent_rl/swe.py:201 · 快照	<module>	async_def	apply_before_repo_set_cmd	python_ast	async def apply_before_repo_set_cmd(sb: Sandbox, workdir: str, swepro: dict) -> None:
occ-000083	examples/coding_agent_rl/swe.py:207 · 快照	apply_before_repo_set_cmd	await	await	python_ast	await sb.exec(
occ-000084	examples/coding_agent_rl/swe.py:210 · 快照	apply_before_repo_set_cmd	await	await	python_ast	await sb.write_file("/workspace/swepro_setup/before.sh", payload, user=“agent”)
occ-000085	examples/coding_agent_rl/swe.py:211 · 快照	apply_before_repo_set_cmd	await	await	python_ast	await sb.exec(“bash /workspace/swepro_setup/before.sh”, user=“agent”, check=False, timeout=600)
occ-000086	examples/coding_agent_rl/swe.py:214 · 快照	<module>	async_def	apply_pre_commands	python_ast	async def apply_pre_commands(sb: Sandbox, workdir: str, pre: list[str] \| str) -> None:
occ-000088	examples/coding_agent_rl/swe.py:223 · 快照	apply_pre_commands	await	await	python_ast	await sb.write_file(_PRE, “set -e\n” + body, user=“agent”)
occ-000089	examples/coding_agent_rl/swe.py:224 · 快照	apply_pre_commands	await	await	python_ast	await sb.exec(f"chmod 755 {_PRE} && cd {workdir} && bash {_PRE}", user=“agent”, check=False, timeout=600)
occ-000090	examples/coding_agent_rl/swe.py:230 · 快照	<module>	async_def	git_diff	python_ast	async def git_diff(sb: Sandbox, workdir: str) -> str:
occ-000091	examples/coding_agent_rl/swe.py:232 · 快照	git_diff	await	await	python_ast	_, out, _ = await sb.exec(cmd, user=“agent”, timeout=120)
occ-000092	examples/coding_agent_rl/swe.py:239 · 快照	<module>	async_def	run_evaluation	python_ast	async def run_evaluation(md: dict, *, diff_text: str, timeout_sec: int) -> EvalResult:
occ-000094	examples/coding_agent_rl/swe.py:246 · 快照	run_evaluation	await	await	python_ast	return await _grade_swebench(md, diff_text, timeout_sec)
occ-000095	examples/coding_agent_rl/swe.py:247 · 快照	run_evaluation	await	await	python_ast	return await _grade_scaleswe(md, diff_text, timeout_sec)
occ-000096	examples/coding_agent_rl/swe.py:253 · 快照	<module>	async_def	_grade_scaleswe	python_ast	async def _grade_scaleswe(md: dict, diff_text: str, timeout_sec: int) -> EvalResult:
occ-000102	examples/coding_agent_rl/swe.py:269 · 快照	_grade_scaleswe	async_with	async with	python_ast	async with E2BSandbox(image) as ev:
occ-000103	examples/coding_agent_rl/swe.py:270 · 快照	_grade_scaleswe	await	await	python_ast	await agent_sandbox.ensure_agent_user(ev, workdir)
occ-000104	examples/coding_agent_rl/swe.py:272 · 快照	_grade_scaleswe	await	await	python_ast	await _setup_swepro_assets(ev, swepro)
occ-000105	examples/coding_agent_rl/swe.py:273 · 快照	_grade_scaleswe	await	await	python_ast	await apply_before_repo_set_cmd(ev, workdir, swepro)
occ-000106	examples/coding_agent_rl/swe.py:275 · 快照	_grade_scaleswe	await	await	python_ast	await apply_pre_commands(ev, workdir, pre_commands)
occ-000107	examples/coding_agent_rl/swe.py:277 · 快照	_grade_scaleswe	await	await	python_ast	applied = await _apply_diff(ev, workdir, diff_text)
occ-000108	examples/coding_agent_rl/swe.py:282 · 快照	_grade_scaleswe	await	await	python_ast	r = await _run_swepro(ev, workdir, swepro, timeout_sec)
occ-000109	examples/coding_agent_rl/swe.py:284 · 快照	_grade_scaleswe	await	await	python_ast	r = await _run_eval_cmd(ev, workdir, eval_cmd, timeout_sec)
occ-000110	examples/coding_agent_rl/swe.py:286 · 快照	_grade_scaleswe	await	await	python_ast	r = await _run_f2p_script(ev, workdir, f2p_script, timeout_sec)
occ-000111	examples/coding_agent_rl/swe.py:290 · 快照	<module>	async_def	_setup_swepro_assets	python_ast	async def _setup_swepro_assets(ev: Sandbox, swepro: dict) -> None:
occ-000112	examples/coding_agent_rl/swe.py:291 · 快照	_setup_swepro_assets	await	await	python_ast	await ev.exec(f"mkdir -p {_SWEPRO_DIR} && chmod 777 {_SWEPRO_DIR}", user=“root”, check=True)
occ-000114	examples/coding_agent_rl/swe.py:295 · 快照	_setup_swepro_assets	await	await	python_ast	await ev.write_file(f"{_SWEPRO_DIR}/{dst}", Path(host_p), user=“root”)
occ-000115	examples/coding_agent_rl/swe.py:296 · 快照	_setup_swepro_assets	await	await	python_ast	await ev.exec(f"chmod 755 {_SWEPRO_DIR}/* && chown -R agent:agent {_SWEPRO_DIR}", user=“root”, check=True)
occ-000116	examples/coding_agent_rl/swe.py:299 · 快照	<module>	async_def	_apply_diff	python_ast	async def _apply_diff(ev: Sandbox, workdir: str, diff_text: str) -> bool:
occ-000117	examples/coding_agent_rl/swe.py:302 · 快照	_apply_diff	await	await	python_ast	await ev.write_file(_PATCH, diff_text, user=“agent”)
occ-000119	examples/coding_agent_rl/swe.py:312 · 快照	_apply_diff	await	await	python_ast	ec, _, _ = await ev.exec(f"cd {workdir} && ({ladder})", user=“agent”, check=False, timeout=120)
occ-000120	examples/coding_agent_rl/swe.py:316 · 快照	<module>	async_def	_run_swepro	python_ast	async def _run_swepro(ev: Sandbox, workdir: str, swepro: dict, timeout: int) -> float:
occ-000123	examples/coding_agent_rl/swe.py:321 · 快照	_run_swepro	await	await	python_ast	await ev.exec(
occ-000124	examples/coding_agent_rl/swe.py:327 · 快照	_run_swepro	await	await	python_ast	await ev.exec(
occ-000125	examples/coding_agent_rl/swe.py:333 · 快照	_run_swepro	await	await	python_ast	raw = await ev.read_file(result_f, user=“agent”)
occ-000130	examples/coding_agent_rl/swe.py:341 · 快照	<module>	async_def	_run_eval_cmd	python_ast	async def _run_eval_cmd(ev: Sandbox, workdir: str, cmd: str, timeout: int) -> float:
occ-000131	examples/coding_agent_rl/swe.py:342 · 快照	_run_eval_cmd	await	await	python_ast	ec, _, _ = await ev.exec(f"cd {workdir} && {cmd}", user=“agent”, check=False, timeout=timeout)
occ-000132	examples/coding_agent_rl/swe.py:346 · 快照	<module>	async_def	_run_f2p_script	python_ast	async def _run_f2p_script(ev: Sandbox, workdir: str, script: str, timeout: int) -> float:
occ-000133	examples/coding_agent_rl/swe.py:350 · 快照	_run_f2p_script	await	await	python_ast	await ev.write_file(_F2P, script, user=“agent”)
occ-000134	examples/coding_agent_rl/swe.py:351 · 快照	_run_f2p_script	await	await	python_ast	ec, _, _ = await ev.exec(f"cd {workdir} && python {_F2P}", user=“agent”, check=False, timeout=timeout)
occ-000135	examples/coding_agent_rl/swe.py:364 · 快照	<module>	async_def	_apply_model_patch	python_ast	async def _apply_model_patch(ev: Sandbox, workdir: str) -> bool:
occ-000137	examples/coding_agent_rl/swe.py:373 · 快照	_apply_model_patch	await	await	python_ast	ec, _, _ = await ev.exec(cmd, user=“root”, check=False, timeout=120)
occ-000147	examples/coding_agent_rl/swe.py:440 · 快照	<module>	async_def	_grade_swebench	python_ast	async def _grade_swebench(md: dict, diff_text: str, timeout_sec: int) -> EvalResult:
occ-000148	examples/coding_agent_rl/swe.py:465 · 快照	_grade_swebench	async_with	async with	python_ast	async with E2BSandbox(image) as ev:
occ-000149	examples/coding_agent_rl/swe.py:466 · 快照	_grade_swebench	await	await	python_ast	await asyncio.gather(
occ-000151	examples/coding_agent_rl/swe.py:472 · 快照	_grade_swebench	await	await	python_ast	if not await _apply_model_patch(ev, md[“workdir”]):
occ-000152	examples/coding_agent_rl/swe.py:475 · 快照	_grade_swebench	await	await	python_ast	exit_code, log = await exec_and_wait(
occ-000160	examples/geo3k_vlm_multi_turn/rollout.py:192 · 快照	<module>	async_def	_run_inference_step	python_ast	async def _run_inference_step(url: str, tokens: list[int], sampling_params: dict, image_data, tokenizer):
occ-000161	examples/geo3k_vlm_multi_turn/rollout.py:201 · 快照	_run_inference_step	await	await	python_ast	output = await post(url, payload)
occ-000162	examples/geo3k_vlm_multi_turn/rollout.py:315 · 快照	<module>	async_def	generate	python_ast	async def generate(args: Any, sample: Sample, sampling_params) -> Sample:
occ-000164	examples/geo3k_vlm_multi_turn/rollout.py:336 · 快照	generate	await	await	python_ast	await _run_inference_step(url, sample.tokens, cur_sampling_params, current_image_data, state.tokenizer)
occ-000168	examples/multi_agent/agent_system.py:14 · 快照	<module>	async_def	generate_response	python_ast	async def generate_response(args, prompt, key):
occ-000169	examples/multi_agent/agent_system.py:37 · 快照	generate_response	await	await	python_ast	output = await post(url, payload)
occ-000170	examples/multi_agent/agent_system.py:95 · 快照	Agent	async_def	run	python_ast	async def run(self, args, prompt, max_retries: int = 1, key: str = None) -> str:
occ-000171	examples/multi_agent/agent_system.py:99 · 快照	Agent.run	await	await	python_ast	response = await generate_response(args, prompt, key=key)
occ-000173	examples/multi_agent/agent_system.py:114 · 快照	SolverAgent	async_def	generate_initial_solution	python_ast	async def generate_initial_solution(self, args, problem_statement) -> str:
occ-000174	examples/multi_agent/agent_system.py:117 · 快照	SolverAgent.generate_initial_solution	await	await	python_ast	return await self.run(args, prompt, max_retries=3, key=“solver”)
occ-000175	examples/multi_agent/agent_system.py:126 · 快照	RewriterAgent	async_def	rewrite	python_ast	async def rewrite(self, args, problem_statement, previous_solutions: list[str]) -> str:
occ-000176	examples/multi_agent/agent_system.py:138 · 快照	RewriterAgent.rewrite	await	await	python_ast	return await self.run(args, prompt, max_retries=1, key=“rewriter”)
occ-000177	examples/multi_agent/agent_system.py:147 · 快照	SelectorAgent	async_def	select	python_ast	async def select(self, args, problem_statement, candidate_solutions: list[str]) -> str:
occ-000178	examples/multi_agent/agent_system.py:159 · 快照	SelectorAgent.select	await	await	python_ast	return await self.run(args, prompt, max_retries=10, key=“selector”)
occ-000179	examples/multi_agent/agent_system.py:176 · 快照	<module>	async_def	rewrite_worker	python_ast	async def rewrite_worker(args, previous_solutions, problem_statement, worker_id):
occ-000180	examples/multi_agent/agent_system.py:178 · 快照	rewrite_worker	await	await	python_ast	new_solution = await rewriter.rewrite(args, problem_statement, previous_solutions)
occ-000181	examples/multi_agent/agent_system.py:182 · 快照	<module>	async_def	solver_worker	python_ast	async def solver_worker(args, problem_statement, worker_id):
occ-000182	examples/multi_agent/agent_system.py:189 · 快照	solver_worker	await	await	python_ast	current_solution = await solver.generate_initial_solution(args, problem_statement)
occ-000183	examples/multi_agent/agent_system.py:198 · 快照	<module>	async_def	run_agent_system	python_ast	async def run_agent_system(args, sample):
occ-000184	examples/multi_agent/agent_system.py:222 · 快照	run_agent_system	await	await	python_ast	results = await asyncio.gather(*tasks, return_exceptions=True)
occ-000186	examples/multi_agent/agent_system.py:224 · 快照	run_agent_system	await	await	python_ast	rewards = await batched_async_rm(args, args.results_dict[“solver”])
occ-000187	examples/multi_agent/agent_system.py:244 · 快照	run_agent_system	await	await	python_ast	rewrited_solutions_raw = await asyncio.gather(*tasks, return_exceptions=True)
occ-000189	examples/multi_agent/agent_system.py:252 · 快照	run_agent_system	await	await	python_ast	rewards = await batched_async_rm(args, args.results_dict[“rewriter”])
occ-000190	examples/multi_agent/agent_system.py:263 · 快照	run_agent_system	await	await	python_ast	response = await selector.select(args, problem_statement, rewrited_solutions)
occ-000191	examples/multi_agent/rollout_with_multi_agents.py:16 · 快照	<module>	async_def	generate_with_multi_agents	python_ast	async def generate_with_multi_agents(args, sample: Sample, sampling_params, evaluation=False) -> list[Sample]:
occ-000192	examples/multi_agent/rollout_with_multi_agents.py:29 · 快照	generate_with_multi_agents	await	await	python_ast	samples = await custom_multi_agent_func(args, sample)
occ-000196	examples/retool/generate_with_retool.py:183 · 快照	<module>	async_def	execute_predictions	python_ast	async def execute_predictions(prediction: str) -> str:
occ-000197	examples/retool/generate_with_retool.py:192 · 快照	execute_predictions	async_with	async with	python_ast	async with SEMAPHORE:
occ-000198	examples/retool/generate_with_retool.py:193 · 快照	execute_predictions	await	await	python_ast	result = await tool_registry.execute_tool(“code_interpreter”, {“code”: code})
occ-000199	examples/retool/generate_with_retool.py:215 · 快照	<module>	async_def	generate	python_ast	async def generate(args, sample: Sample, sampling_params) -> Sample:
occ-000201	examples/retool/generate_with_retool.py:299 · 快照	generate	await	await	python_ast	output = await post(url, payload)
occ-000202	examples/retool/generate_with_retool.py:335 · 快照	generate	await	await	python_ast	next_obs, done = await execute_predictions(cur_response)
occ-000203	examples/retool/generate_with_retool.py:407 · 快照	<module>	async_def	reward_func	python_ast	async def reward_func(args, sample, **kwargs):
occ-000207	examples/retool/tool_sandbox.py:193 · 快照	PythonSandbox	async_def	execute_code	python_ast	async def execute_code(self, code: str) -> str:
occ-000216	examples/retool/tool_sandbox.py:337 · 快照	ToolRegistry	async_def	execute_tool	python_ast	async def execute_tool(self, tool_name: str, arguments: dict[str, Any]) -> str:
occ-000217	examples/retool/tool_sandbox.py:342 · 快照	ToolRegistry.execute_tool	async_with	async with	python_ast	async with SEMAPHORE:
occ-000218	examples/retool/tool_sandbox.py:344 · 快照	ToolRegistry.execute_tool	await	await	python_ast	return await self._execute_python(arguments)
occ-000219	examples/retool/tool_sandbox.py:348 · 快照	ToolRegistry	async_def	_execute_python	python_ast	async def _execute_python(self, arguments: dict[str, Any]) -> str:
occ-000221	examples/retool/tool_sandbox.py:355 · 快照	ToolRegistry._execute_python	await	await	python_ast	result = await self.python_sandbox.execute_code(code)
occ-000225	examples/search-r1/generate_with_search.py:59 · 快照	<module>	async_def	search	python_ast	async def search(query: str) -> str:
occ-000226	examples/search-r1/generate_with_search.py:70 · 快照	search	await	await	python_ast	result = await local_search(
occ-000227	examples/search-r1/generate_with_search.py:80 · 快照	search	await	await	python_ast	result = await google_search(
occ-000228	examples/search-r1/generate_with_search.py:124 · 快照	<module>	async_def	execute_predictions	python_ast	async def execute_predictions(prediction: str) -> str:
occ-000229	examples/search-r1/generate_with_search.py:129 · 快照	execute_predictions	async_with	async with	python_ast	async with SEMAPHORE:
occ-000230	examples/search-r1/generate_with_search.py:130 · 快照	execute_predictions	await	await	python_ast	search_results = await search(search_query)
occ-000231	examples/search-r1/generate_with_search.py:145 · 快照	<module>	async_def	generate	python_ast	async def generate(args, sample: Sample, sampling_params) -> Sample:
occ-000233	examples/search-r1/generate_with_search.py:188 · 快照	generate	await	await	python_ast	output = await post(url, payload)
occ-000234	examples/search-r1/generate_with_search.py:235 · 快照	generate	await	await	python_ast	next_obs, done = await execute_predictions(cur_response)
occ-000235	examples/search-r1/generate_with_search.py:277 · 快照	<module>	async_def	reward_func	python_ast	async def reward_func(args, sample, **kwargs):
occ-000238	examples/search-r1/google_search_server.py:42 · 快照	<module>	async_def	fetch	python_ast	async def fetch(session: aiohttp.ClientSession, url: str, semaphore: asyncio.Semaphore) -> str:
occ-000240	examples/search-r1/google_search_server.py:52 · 快照	fetch	async_with	async with	python_ast	async with semaphore:
occ-000241	examples/search-r1/google_search_server.py:54 · 快照	fetch	async_with	async with	python_ast	async with session.get(url, headers=headers) as response:
occ-000243	examples/search-r1/google_search_server.py:55 · 快照	fetch	await	await	python_ast	raw = await response.read()
occ-000246	examples/search-r1/google_search_server.py:63 · 快照	<module>	async_def	fetch_all	python_ast	async def fetch_all(urls: list[str], limit: int = 8) -> list[str]:
occ-000248	examples/search-r1/google_search_server.py:68 · 快照	fetch_all	async_with	async with	python_ast	async with aiohttp.ClientSession(timeout=timeout, connector=connector) as session:
occ-000249	examples/search-r1/google_search_server.py:70 · 快照	fetch_all	await	await	python_ast	return await asyncio.gather(*tasks)
occ-000252	examples/search-r1/google_search_server.py:94 · 快照	<module>	async_def	google_search	python_ast	async def google_search(api_key, query, top_k=5, timeout: int = 60, proxy=None, snippet_only=False) -> list[dict]:
occ-000253	examples/search-r1/google_search_server.py:99 · 快照	google_search	async_with	async with	python_ast	async with aiohttp.ClientSession(**session_kwargs) as session:
occ-000254	examples/search-r1/google_search_server.py:100 · 快照	google_search	async_with	async with	python_ast	async with session.post(
occ-000255	examples/search-r1/google_search_server.py:115 · 快照	google_search	await	await	python_ast	response = await resp.json()
occ-000261	examples/search-r1/google_search_server.py:133 · 快照	google_search	await	await	python_ast	web_contents = await fetch_all(links)
occ-000264	examples/search-r1/local_search_server.py:25 · 快照	<module>	async_def	local_search	python_ast	async def local_search(
occ-000265	examples/search-r1/local_search_server.py:66 · 快照	local_search	async_with	async with	python_ast	async with aiohttp.ClientSession(**session_kwargs) as session:
occ-000266	examples/search-r1/local_search_server.py:67 · 快照	local_search	async_with	async with	python_ast	async with session.post(search_url, json=payload, timeout=timeout_obj) as resp:
occ-000267	examples/search-r1/local_search_server.py:69 · 快照	local_search	await	await	python_ast	result = await resp.json()
occ-000270	examples/strands_sglang/generate_with_strands.py:41 · 快照	<module>	async_def	generate	python_ast	async def generate(args, sample: Sample, sampling_params) -> Sample:
occ-000271	examples/strands_sglang/generate_with_strands.py:66 · 快照	generate	await	await	python_ast	await agent.invoke_async(prompt)
occ-000273	examples/strands_sglang/generate_with_strands.py:90 · 快照	<module>	async_def	reward_func	python_ast	async def reward_func(args, sample: Sample, **kwargs):
occ-000294	examples/tau-bench/generate_with_tau.py:100 · 快照	<module>	async_def	generate	python_ast	async def generate(args: dict[str, Any], sample: Sample, sampling_params: dict) -> Sample:
occ-000295	examples/tau-bench/generate_with_tau.py:147 · 快照	generate	await	await	python_ast	interaction_result = await agent.asolve(env, agent.rollout_args, agent.sampling_params, task_index)
occ-000296	examples/tau-bench/trainable_agents.py:91 · 快照	TrainableAgentMixin	async_def	_call_llm	python_ast	async def _call_llm(self, url: str, payload: dict[str, Any]) -> dict[str, Any]:
occ-000297	examples/tau-bench/trainable_agents.py:102 · 快照	TrainableAgentMixin._call_llm	await	await	python_ast	return await post(url, payload)
occ-000298	examples/tau-bench/trainable_agents.py:116 · 快照	TrainableAgentMixin	async_def	_execute_tool	python_ast	async def _execute_tool(self, env, action: Action):
occ-000301	examples/tau-bench/trainable_agents.py:177 · 快照	TrainableAgentMixin	async_def	asolve	python_ast	async def asolve(
occ-000302	examples/tau-bench/trainable_agents.py:232 · 快照	TrainableAgentMixin.asolve	await	await	python_ast	output = await self._call_llm(url, payload)
occ-000303	examples/tau-bench/trainable_agents.py:293 · 快照	TrainableAgentMixin.asolve	await	await	python_ast	env_response = await self._execute_tool(env, action)
occ-000309	slime/agent/adapters/anthropic.py:71 · 快照	AnthropicAdapter	async_def	_respond	python_ast	async def _respond(self, request, body, reply, in_tok, out_tok, stream) -> web.StreamResponse:
occ-000310	slime/agent/adapters/anthropic.py:74 · 快照	AnthropicAdapter._respond	await	await	python_ast	return await _render_stream(request, blocks, stop_reason, in_tok, out_tok)
occ-000332	slime/agent/adapters/anthropic.py:211 · 快照	<module>	async_def	_render_stream	python_ast	async def _render_stream(request, blocks, stop_reason, in_tok, out_tok) -> web.StreamResponse:
occ-000333	slime/agent/adapters/anthropic.py:223 · 快照	_render_stream	await	await	python_ast	await out.prepare(request)
occ-000334	slime/agent/adapters/anthropic.py:238 · 快照	_render_stream	await	await	python_ast	await out.write(f"event: message_start\ndata: {json.dumps(ms_data, ensure_ascii=False)}\n\n".encode())
occ-000336	slime/agent/adapters/anthropic.py:256 · 快照	_render_stream	await	await	python_ast	await out.write(f"event: content_block_start\ndata: {json.dumps(cbs_data, ensure_ascii=False)}\n\n".encode())
occ-000338	slime/agent/adapters/anthropic.py:259 · 快照	_render_stream	await	await	python_ast	await out.write(f"event: content_block_delta\ndata: {json.dumps(cbd_data, ensure_ascii=False)}\n\n".encode())
occ-000340	slime/agent/adapters/anthropic.py:262 · 快照	_render_stream	await	await	python_ast	await out.write(f"event: content_block_stop\ndata: {json.dumps(cbe_data, ensure_ascii=False)}\n\n".encode())
occ-000342	slime/agent/adapters/anthropic.py:269 · 快照	_render_stream	await	await	python_ast	await out.write(f"event: message_delta\ndata: {json.dumps(md_data, ensure_ascii=False)}\n\n".encode())
occ-000344	slime/agent/adapters/anthropic.py:272 · 快照	_render_stream	await	await	python_ast	await out.write(f"event: message_stop\ndata: {json.dumps(mst_data, ensure_ascii=False)}\n\n".encode())
occ-000346	slime/agent/adapters/anthropic.py:279 · 快照	<module>	async_def	_count_tokens	python_ast	async def _count_tokens(request: web.Request) -> web.Response:
occ-000347	slime/agent/adapters/anthropic.py:280 · 快照	_count_tokens	await	await	python_ast	await request.read()
occ-000363	slime/agent/adapters/common.py:197 · 快照	BaseAdapter	async_def	_respond	python_ast	async def _respond(
occ-000364	slime/agent/adapters/common.py:225 · 快照	BaseAdapter	async_def	shutdown_session	python_ast	async def shutdown_session(self, sid: str, *, wait_timeout: float = 5.0) -> None:
occ-000366	slime/agent/adapters/common.py:232 · 快照	BaseAdapter.shutdown_session	async_def	_drain	python_ast	async def _drain() -> None:
occ-000367	slime/agent/adapters/common.py:233 · 快照	BaseAdapter.shutdown_session._drain	await	await	python_ast	_, pending = await asyncio.wait(tasks, timeout=wait_timeout)
occ-000370	slime/agent/adapters/common.py:237 · 快照	BaseAdapter.shutdown_session._drain	await	await	python_ast	await asyncio.gather(*pending, return_exceptions=True)
occ-000373	slime/agent/adapters/common.py:241 · 快照	BaseAdapter.shutdown_session	await	await	python_ast	await asyncio.wrap_future(asyncio.run_coroutine_threadsafe(_drain(), loop))
occ-000377	slime/agent/adapters/common.py:245 · 快照	BaseAdapter	async_def	finish_session	python_ast	async def finish_session(
occ-000378	slime/agent/adapters/common.py:261 · 快照	BaseAdapter.finish_session	await	await	python_ast	await self.shutdown_session(sid, wait_timeout=wait_timeout)
occ-000379	slime/agent/adapters/common.py:278 · 快照	BaseAdapter	async_def	drop_session	python_ast	async def drop_session(self, sid: str, *, wait_timeout: float = 5.0) -> None:
occ-000380	slime/agent/adapters/common.py:279 · 快照	BaseAdapter.drop_session	await	await	python_ast	await self.shutdown_session(sid, wait_timeout=wait_timeout)
occ-000383	slime/agent/adapters/common.py:318 · 快照	BaseAdapter	async_def	_run_turn	python_ast	async def _run_turn(self, request: web.Request) -> web.StreamResponse:
occ-000384	slime/agent/adapters/common.py:325 · 快照	BaseAdapter._run_turn	await	await	python_ast	body = await request.json()
occ-000386	slime/agent/adapters/common.py:344 · 快照	BaseAdapter._run_turn	await	await	python_ast	turn = await call_sglang_generate(prompt_ids, s, body, adapter=self, session_id=sid)
occ-000389	slime/agent/adapters/common.py:363 · 快照	BaseAdapter._run_turn	await	await	python_ast	response = await self._respond(request, body, reply, in_tok, out_tok, stream)
occ-000400	slime/agent/adapters/common.py:442 · 快照	<module>	async_def	call_sglang_generate	python_ast	async def call_sglang_generate(
occ-000402	slime/agent/adapters/common.py:475 · 快照	call_sglang_generate	async_with	async with	python_ast	async with aiohttp.ClientSession(timeout=timeout) as sess, sess.post(
occ-000403	slime/agent/adapters/common.py:486 · 快照	call_sglang_generate	await	await	python_ast	text = await r.text()
occ-000404	slime/agent/adapters/common.py:496 · 快照	call_sglang_generate	await	await	python_ast	data = await r.json(content_type=None)
occ-000411	slime/agent/adapters/common.py:506 · 快照	call_sglang_generate	await	await	python_ast	await _abort_sglang_request(sglang_url, rid, logger)
occ-000412	slime/agent/adapters/common.py:517 · 快照	<module>	async_def	_abort_sglang_request	python_ast	async def _abort_sglang_request(sglang_url: str, rid: str, logger: logging.Logger) -> None:
occ-000413	slime/agent/adapters/common.py:521 · 快照	_abort_sglang_request	async_with	async with	python_ast	async with aiohttp.ClientSession(timeout=timeout) as session:
occ-000414	slime/agent/adapters/common.py:523 · 快照	_abort_sglang_request	async_def	abort_worker	python_ast	async def abort_worker(url: str) -> None:
occ-000415	slime/agent/adapters/common.py:525 · 快照	_abort_sglang_request.abort_worker	async_with	async with	python_ast	async with session.post(f"{url}/abort_request", json={“rid”: rid}):
occ-000416	slime/agent/adapters/common.py:530 · 快照	_abort_sglang_request	async_with	async with	python_ast	async with session.get(f"{sglang_url}/workers") as response:
occ-000418	slime/agent/adapters/common.py:532 · 快照	_abort_sglang_request	await	await	python_ast	await abort_worker(sglang_url)
occ-000419	slime/agent/adapters/common.py:535 · 快照	_abort_sglang_request	await	await	python_ast	payload = await response.json()
occ-000422	slime/agent/adapters/common.py:547 · 快照	_abort_sglang_request	await	await	python_ast	await asyncio.gather(*(abort_worker(url) for url in worker_urls))
occ-000424	slime/agent/adapters/common.py:557 · 快照	<module>	async_def	_health	python_ast	async def _health(request: web.Request) -> web.Response:
occ-000427	slime/agent/adapters/openai.py:69 · 快照	OpenAIAdapter	async_def	_respond	python_ast	async def _respond(self, request, body, reply, in_tok, out_tok, stream) -> web.StreamResponse:
occ-000428	slime/agent/adapters/openai.py:72 · 快照	OpenAIAdapter._respond	await	await	python_ast	return await _render_stream(request, body, wire_message, wire_finish, in_tok, out_tok)
occ-000451	slime/agent/adapters/openai.py:324 · 快照	<module>	async_def	_render_stream	python_ast	async def _render_stream(
occ-000452	slime/agent/adapters/openai.py:347 · 快照	_render_stream	await	await	python_ast	await out.prepare(request)
occ-000453	slime/agent/adapters/openai.py:351 · 快照	_render_stream	async_def	emit	python_ast	async def emit(delta: dict[str, Any], finish_reason: str \| None = None, usage: dict \| None = None) -> None:
occ-000455	slime/agent/adapters/openai.py:361 · 快照	_render_stream.emit	await	await	python_ast	await out.write(f"data: {json.dumps(chunk, ensure_ascii=False)}\n\n".encode())
occ-000457	slime/agent/adapters/openai.py:363 · 快照	_render_stream	await	await	python_ast	await emit({“role”: “assistant”})
occ-000459	slime/agent/adapters/openai.py:366 · 快照	_render_stream	await	await	python_ast	await emit({“reasoning_content”: reasoning})
occ-000461	slime/agent/adapters/openai.py:369 · 快照	_render_stream	await	await	python_ast	await emit({“content”: content})
occ-000463	slime/agent/adapters/openai.py:375 · 快照	_render_stream	await	await	python_ast	await emit({“tool_calls”: [{**call, “index”: idx} for idx, call in enumerate(tool_calls)]})
occ-000464	slime/agent/adapters/openai.py:376 · 快照	_render_stream	await	await	python_ast	await emit({}, finish_reason=wire_finish, usage=_usage(in_tok, out_tok))
occ-000465	slime/agent/adapters/openai.py:377 · 快照	_render_stream	await	await	python_ast	await out.write(b"data: [DONE]\n\n")
occ-000471	slime/agent/aiohttp_threaded.py:34 · 快照	AppHandle.stop	async_def	_shutdown	python_ast	async def _shutdown() -> None:
occ-000472	slime/agent/aiohttp_threaded.py:35 · 快照	AppHandle.stop._shutdown	await	await	python_ast	await self.runner.cleanup()
occ-000489	slime/agent/harness/claude_code.py:36 · 快照	ClaudeCodeHarness	async_def	install_cli	python_ast	async def install_cli(self, sb: Sandbox) -> None:
occ-000490	slime/agent/harness/claude_code.py:37 · 快照	ClaudeCodeHarness.install_cli	await	await	python_ast	await install_npm_cli(
occ-000491	slime/agent/harness/claude_code.py:44 · 快照	ClaudeCodeHarness	async_def	write_config	python_ast	async def write_config(self, sb: Sandbox, ctx: HarnessContext) -> None:
occ-000492	slime/agent/harness/claude_code.py:47 · 快照	ClaudeCodeHarness.write_config	await	await	python_ast	await sb.exec(
occ-000493	slime/agent/harness/claude_code.py:57 · 快照	ClaudeCodeHarness	async_def	launch_and_wait	python_ast	async def launch_and_wait(self, sb: Sandbox, ctx: HarnessContext, prompt: str, time_budget_sec: int) -> int:
occ-000494	slime/agent/harness/claude_code.py:71 · 快照	ClaudeCodeHarness.launch_and_wait	await	await	python_ast	return await run_agent(sb, workdir=ctx.workdir, start_cmd=cmd, env=env, time_budget_sec=time_budget_sec)
occ-000495	slime/agent/harness/codex.py:48 · 快照	CodexHarness	async_def	install_cli	python_ast	async def install_cli(self, sb: Sandbox) -> None:
occ-000496	slime/agent/harness/codex.py:49 · 快照	CodexHarness.install_cli	await	await	python_ast	await install_npm_cli(
occ-000497	slime/agent/harness/codex.py:56 · 快照	CodexHarness	async_def	write_config	python_ast	async def write_config(self, sb: Sandbox, ctx: HarnessContext) -> None:
occ-000498	slime/agent/harness/codex.py:59 · 快照	CodexHarness.write_config	await	await	python_ast	await sb.exec(
occ-000499	slime/agent/harness/codex.py:69 · 快照	CodexHarness	async_def	launch_and_wait	python_ast	async def launch_and_wait(self, sb: Sandbox, ctx: HarnessContext, prompt: str, time_budget_sec: int) -> int:
occ-000500	slime/agent/harness/codex.py:86 · 快照	CodexHarness.launch_and_wait	await	await	python_ast	return await run_agent(sb, workdir=ctx.workdir, start_cmd=cmd, env=env, time_budget_sec=time_budget_sec)
occ-000502	slime/agent/harness/common.py:64 · 快照	BaseHarness	async_def	install_cli	python_ast	async def install_cli(self, sb: Sandbox) -> None:
occ-000503	slime/agent/harness/common.py:69 · 快照	BaseHarness	async_def	write_config	python_ast	async def write_config(self, sb: Sandbox, ctx: HarnessContext) -> None:
occ-000504	slime/agent/harness/common.py:73 · 快照	BaseHarness	async_def	launch_and_wait	python_ast	async def launch_and_wait(self, sb: Sandbox, ctx: HarnessContext, prompt: str, time_budget_sec: int) -> int:
occ-000505	slime/agent/harness/common.py:81 · 快照	BaseHarness	async_def	run	python_ast	async def run(
occ-000506	slime/agent/harness/common.py:97 · 快照	BaseHarness.run	await	await	python_ast	await _sandbox.ensure_agent_user(sb, workdir)
occ-000507	slime/agent/harness/common.py:103 · 快照	BaseHarness.run	await	await	python_ast	await self.write_config(sb, ctx)
occ-000508	slime/agent/harness/common.py:104 · 快照	BaseHarness.run	await	await	python_ast	return await self.launch_and_wait(sb, ctx, prompt, time_budget_sec)
occ-000509	slime/agent/harness/common.py:107 · 快照	<module>	async_def	run_agent	python_ast	async def run_agent(sb: Sandbox, *, workdir: str, start_cmd: str, env: dict[str, str], time_budget_sec: int) -> int:
occ-000510	slime/agent/harness/common.py:110 · 快照	run_agent	await	await	python_ast	await sb.exec(f"mkdir -p {meta_dir} && chown agent:agent {meta_dir}", user=“root”, check=True, timeout=30)
occ-000511	slime/agent/harness/common.py:111 · 快照	run_agent	await	await	python_ast	exit_code, _ = await exec_and_wait(
occ-000512	slime/agent/harness/common.py:125 · 快照	<module>	async_def	install_npm_cli	python_ast	async def install_npm_cli(
occ-000513	slime/agent/harness/common.py:135 · 快照	install_npm_cli	await	await	python_ast	await install_node22(sb, node_runtime)
occ-000514	slime/agent/harness/common.py:137 · 快照	install_npm_cli	await	await	python_ast	await sb.write_file("/tmp/harness-cli.tgz", npm_package)
occ-000515	slime/agent/harness/common.py:142 · 快照	install_npm_cli	await	await	python_ast	exit_code, last_log = await exec_and_wait(
occ-000516	slime/agent/harness/common.py:148 · 快照	install_npm_cli	await	await	python_ast	await asyncio.sleep(NPM_INSTALL_BACKOFF_SEC * (attempt + 1))
occ-000518	slime/agent/harness/common.py:154 · 快照	<module>	async_def	install_node22	python_ast	async def install_node22(sb: Sandbox, host_tarball: Path) -> None:
occ-000519	slime/agent/harness/common.py:167 · 快照	install_node22	await	await	python_ast	await sb.write_file("/tmp/node22.tar", host_tarball)
occ-000520	slime/agent/harness/common.py:168 · 快照	install_node22	await	await	python_ast	await sb.exec(
occ-000522	slime/agent/sandbox.py:42 · 快照	Sandbox	async_def	aenter	python_ast	async def aenter(self) -> Sandbox: …
occ-000523	slime/agent/sandbox.py:44 · 快照	Sandbox	async_def	aexit	python_ast	async def aexit(self, exc_type, exc, tb) -> None: …
occ-000524	slime/agent/sandbox.py:46 · 快照	Sandbox	async_def	exec	python_ast	async def exec(
occ-000525	slime/agent/sandbox.py:57 · 快照	Sandbox	async_def	write_file	python_ast	async def write_file(self, sandbox_path: str, content: FileContent, *, user: str = “root”) -> None: …
occ-000526	slime/agent/sandbox.py:59 · 快照	Sandbox	async_def	read_file	python_ast	async def read_file(self, sandbox_path: str, *, user: str = “root”) -> str: …
occ-000527	slime/agent/sandbox.py:65 · 快照	<module>	async_def	_await_done_marker	python_ast	async def _await_done_marker(sb: Sandbox, done_file: str, *, user: str, time_budget_sec: int) -> int:
occ-000528	slime/agent/sandbox.py:75 · 快照	_await_done_marker	await	await	python_ast	await asyncio.sleep(5)
occ-000530	slime/agent/sandbox.py:76 · 快照	_await_done_marker	await	await	python_ast	ec, out, _ = await sb.exec(f"test -f {done_file} && cat {done_file}", user=user, timeout=15, check=False)
occ-000531	slime/agent/sandbox.py:82 · 快照	<module>	async_def	exec_and_wait	python_ast	async def exec_and_wait(
occ-000532	slime/agent/sandbox.py:113 · 快照	exec_and_wait	await	await	python_ast	await sb.write_file(launcher, launcher_body, user=user)
occ-000533	slime/agent/sandbox.py:122 · 快照	exec_and_wait	await	await	python_ast	await sb.exec(
occ-000534	slime/agent/sandbox.py:129 · 快照	exec_and_wait	await	await	python_ast	await sb.exec(
occ-000535	slime/agent/sandbox.py:139 · 快照	exec_and_wait	await	await	python_ast	exit_code = await _await_done_marker(sb, done_file, user=user, time_budget_sec=time_budget_sec)
occ-000536	slime/agent/sandbox.py:143 · 快照	exec_and_wait	await	await	python_ast	return exit_code, await sb.read_file(out_file, user=user)
occ-000537	slime/agent/sandbox.py:144 · 快照	exec_and_wait	await	await	python_ast	_, tail, _ = await sb.exec(f"tail -c 512 {out_file} 2>/dev/null", user=user, timeout=15, check=False)
occ-000538	slime/agent/sandbox.py:237 · 快照	E2BSandbox	async_def	_rpc_retry	python_ast	async def _rpc_retry(self, op_name: str, coro_factory, *, idempotent: bool = True):
occ-000539	slime/agent/sandbox.py:249 · 快照	E2BSandbox._rpc_retry	await	await	python_ast	return await coro_factory()
occ-000540	slime/agent/sandbox.py:257 · 快照	E2BSandbox._rpc_retry	await	await	python_ast	await self._reset_conn_pool()
occ-000541	slime/agent/sandbox.py:269 · 快照	E2BSandbox._rpc_retry	await	await	python_ast	await asyncio.sleep(backoff)
occ-000543	slime/agent/sandbox.py:273 · 快照	E2BSandbox	async_def	_reset_conn_pool	python_ast	async def _reset_conn_pool(self) -> None:
occ-000544	slime/agent/sandbox.py:277 · 快照	E2BSandbox._reset_conn_pool	await	await	python_ast	await pool.aclose()
occ-000545	slime/agent/sandbox.py:281 · 快照	E2BSandbox	async_def	aenter	python_ast	async def aenter(self) -> E2BSandbox:
occ-000546	slime/agent/sandbox.py:298 · 快照	E2BSandbox.aenter	await	await	python_ast	self._sb = await self._rpc_retry(“create”, lambda: AsyncSandbox.create(timeout=self.timeout, metadata=md))
occ-000547	slime/agent/sandbox.py:302 · 快照	E2BSandbox	async_def	aexit	python_ast	async def aexit(self, exc_type, exc, tb) -> None:
occ-000548	slime/agent/sandbox.py:305 · 快照	E2BSandbox.aexit	await	await	python_ast	await self._sb.kill()
occ-000550	slime/agent/sandbox.py:309 · 快照	E2BSandbox	async_def	exec	python_ast	async def exec(
occ-000551	slime/agent/sandbox.py:322 · 快照	E2BSandbox.exec	await	await	python_ast	res = await self._rpc_retry(
occ-000552	slime/agent/sandbox.py:342 · 快照	E2BSandbox	async_def	write_file	python_ast	async def write_file(self, sandbox_path: str, content: FileContent, *, user: str = “root”) -> None:
occ-000553	slime/agent/sandbox.py:346 · 快照	E2BSandbox.write_file	async_def	_do_path	python_ast	async def _do_path():
occ-000554	slime/agent/sandbox.py:348 · 快照	E2BSandbox.write_file._do_path	await	await	python_ast	await self._sb.files.write(
occ-000556	slime/agent/sandbox.py:357 · 快照	E2BSandbox.write_file	await	await	python_ast	await self._rpc_retry(f"write_file({sandbox_path} <- {host_path.name})", _do_path)
occ-000557	slime/agent/sandbox.py:362 · 快照	E2BSandbox.write_file	async_def	_do_bytes	python_ast	async def _do_bytes():
occ-000558	slime/agent/sandbox.py:363 · 快照	E2BSandbox.write_file._do_bytes	await	await	python_ast	await self._sb.files.write(
occ-000560	slime/agent/sandbox.py:372 · 快照	E2BSandbox.write_file	await	await	python_ast	await self._rpc_retry(f"write_file({sandbox_path}, bytes={len(content)})", _do_bytes)
occ-000561	slime/agent/sandbox.py:375 · 快照	E2BSandbox.write_file	await	await	python_ast	await self._rpc_retry(
occ-000563	slime/agent/sandbox.py:380 · 快照	E2BSandbox	async_def	read_file	python_ast	async def read_file(self, sandbox_path: str, *, user: str = “root”) -> str:
occ-000564	slime/agent/sandbox.py:382 · 快照	E2BSandbox.read_file	await	await	python_ast	return await self._rpc_retry(
occ-000566	slime/agent/sandbox.py:390 · 快照	<module>	async_def	ensure_agent_user	python_ast	async def ensure_agent_user(sb: Sandbox, workdir: str) -> None:
occ-000567	slime/agent/sandbox.py:392 · 快照	ensure_agent_user	await	await	python_ast	await sb.exec(
occ-000590	slime/backends/megatron_utils/server/megatron_server.py:355 · 快照	<module>	async_def	_ray_get	python_ast	async def _ray_get(ref):
occ-000591	slime/backends/megatron_utils/server/megatron_server.py:356 · 快照	_ray_get	await	await	python_ast	return await asyncio.to_thread(ray.get, ref)
occ-000593	slime/backends/megatron_utils/server/megatron_server.py:359 · 快照	<module>	async_def	_read_json_payload	python_ast	async def _read_json_payload(request: web.Request) -> dict[str, Any]:
occ-000594	slime/backends/megatron_utils/server/megatron_server.py:363 · 快照	_read_json_payload	await	await	python_ast	payload = await request.json()
occ-000597	slime/backends/megatron_utils/server/megatron_server.py:391 · 快照	<module>	async_def	_wait_until_idle	python_ast	async def _wait_until_idle(sample_manager, timeout_s: float) -> dict[str, Any]:
occ-000598	slime/backends/megatron_utils/server/megatron_server.py:394 · 快照	_wait_until_idle	await	await	python_ast	loads = await _ray_get(sample_manager.get_loads.remote())
occ-000599	slime/backends/megatron_utils/server/megatron_server.py:399 · 快照	_wait_until_idle	await	await	python_ast	await asyncio.sleep(0.1)
occ-000605	slime/backends/megatron_utils/server/megatron_server.py:431 · 快照	_build_http_app	async_def	detect	python_ast	async def detect(_request: web.Request) -> web.Response:
occ-000606	slime/backends/megatron_utils/server/megatron_server.py:434 · 快照	_build_http_app	async_def	healthz	python_ast	async def healthz(_request: web.Request) -> web.Response:
occ-000607	slime/backends/megatron_utils/server/megatron_server.py:437 · 快照	_build_http_app	async_def	info	python_ast	async def info(_request: web.Request) -> web.Response:
occ-000608	slime/backends/megatron_utils/server/megatron_server.py:440 · 快照	_build_http_app	async_def	get_loads	python_ast	async def get_loads(_request: web.Request) -> web.Response:
occ-000609	slime/backends/megatron_utils/server/megatron_server.py:441 · 快照	_build_http_app.get_loads	await	await	python_ast	return web.json_response(await _ray_get(sample_manager.get_loads.remote()))
occ-000610	slime/backends/megatron_utils/server/megatron_server.py:443 · 快照	_build_http_app	async_def	update_from_disk	python_ast	async def update_from_disk(request: web.Request) -> web.Response:
occ-000611	slime/backends/megatron_utils/server/megatron_server.py:447 · 快照	_build_http_app.update_from_disk	await	await	python_ast	payload = await _read_json_payload(request)
occ-000612	slime/backends/megatron_utils/server/megatron_server.py:452 · 快照	_build_http_app.update_from_disk	async_with	async with	python_ast	async with update_lock:
occ-000615	slime/backends/megatron_utils/server/megatron_server.py:471 · 快照	_build_http_app.update_from_disk	await	await	python_ast	result = await asyncio.shield(update_future)
occ-000620	slime/backends/megatron_utils/server/megatron_server.py:482 · 快照	_build_http_app.update_from_disk	await	await	python_ast	before_loads = await _wait_until_idle(sample_manager, timeout_s)
occ-000621	slime/backends/megatron_utils/server/megatron_server.py:483 · 快照	_build_http_app.update_from_disk	await	await	python_ast	update_result = await asyncio.to_thread(update_from_disk_fn, model_path)
occ-000623	slime/backends/megatron_utils/server/megatron_server.py:484 · 快照	_build_http_app.update_from_disk	await	await	python_ast	after_loads = await _ray_get(sample_manager.get_loads.remote())
occ-000624	slime/backends/megatron_utils/server/megatron_server.py:504 · 快照	_build_http_app.update_from_disk	async_with	async with	python_ast	async with update_lock:
occ-000627	slime/backends/megatron_utils/server/megatron_server.py:517 · 快照	_build_http_app	async_def	generate	python_ast	async def generate(request: web.Request) -> web.Response:
occ-000628	slime/backends/megatron_utils/server/megatron_server.py:521 · 快照	_build_http_app.generate	await	await	python_ast	payload = await _read_json_payload(request)
occ-000631	slime/backends/megatron_utils/server/megatron_server.py:548 · 快照	_build_http_app.generate	await	await	python_ast	stats = await _ray_get(sample_manager.get_stats.remote())
occ-000632	slime/backends/megatron_utils/server/megatron_server.py:570 · 快照	_build_http_app.generate	await	await	python_ast	request_id = await _ray_get(
occ-000633	slime/backends/megatron_utils/server/megatron_server.py:581 · 快照	_build_http_app.generate	await	await	python_ast	result = await _ray_get(sample_manager.get_result.remote(request_id))
occ-000634	slime/backends/megatron_utils/server/megatron_server.py:584 · 快照	_build_http_app.generate	await	await	python_ast	await asyncio.sleep(0.05)
occ-000637	slime/backends/megatron_utils/server/megatron_server.py:588 · 快照	_build_http_app.generate	await	await	python_ast	await _ray_get(sample_manager.cancel_request.remote(request_id))
occ-000670	slime/backends/sglang_utils/server_control.py:31 · 快照	<module>	async_def	get_live_router_workers	python_ast	async def get_live_router_workers(router_url: str, *, timeout: float) -> list[dict]:
occ-000671	slime/backends/sglang_utils/server_control.py:38 · 快照	get_live_router_workers	async_with	async with	python_ast	async with httpx.AsyncClient(timeout=timeout, trust_env=False) as client:
occ-000672	slime/backends/sglang_utils/server_control.py:39 · 快照	get_live_router_workers	await	await	python_ast	response = await client.get(f"{router_url}/workers")
occ-000674	slime/backends/sglang_utils/server_control.py:42 · 快照	get_live_router_workers	async_def	check	python_ast	async def check(worker):
occ-000675	slime/backends/sglang_utils/server_control.py:44 · 快照	get_live_router_workers.check	await	await	python_ast	response = await client.get(f"{worker[‘url’]}/health_generate")
occ-000677	slime/backends/sglang_utils/server_control.py:50 · 快照	get_live_router_workers.check	await	await	python_ast	response = await client.delete(f"{router_url}/workers/{worker[‘id’]}")
occ-000678	slime/backends/sglang_utils/server_control.py:57 · 快照	get_live_router_workers	await	await	python_ast	workers = await asyncio.gather(*(check(worker) for worker in response.json()[“workers”]))
occ-000694	slime/backends/sglang_utils/server_control.py:152 · 快照	<module>	async_def	_abort_server_once	python_ast	async def _abort_server_once(url: str, request_timeout: float) -> None:
occ-000695	slime/backends/sglang_utils/server_control.py:153 · 快照	_abort_server_once	await	await	python_ast	await asyncio.wait_for(
occ-000697	slime/backends/sglang_utils/server_control.py:159 · 快照	<module>	async_def	_get_server_load	python_ast	async def _get_server_load(url: str, request_timeout: float) -> Any:
occ-000698	slime/backends/sglang_utils/server_control.py:160 · 快照	_get_server_load	await	await	python_ast	return await asyncio.wait_for(
occ-000700	slime/backends/sglang_utils/server_control.py:166 · 快照	<module>	async_def	abort_server_until_idle	python_ast	async def abort_server_until_idle(
occ-000702	slime/backends/sglang_utils/server_control.py:199 · 快照	abort_server_until_idle	await	await	python_ast	await _abort_server_once(url, per_request_timeout)
occ-000703	slime/backends/sglang_utils/server_control.py:210 · 快照	abort_server_until_idle	await	await	python_ast	load = await _get_server_load(url, min(request_timeout, remaining))
occ-000704	slime/backends/sglang_utils/server_control.py:233 · 快照	abort_server_until_idle	await	await	python_ast	await asyncio.sleep(min(retry_interval, remaining))
occ-000706	slime/backends/sglang_utils/server_control.py:237 · 快照	<module>	async_def	abort_servers_until_idle	python_ast	async def abort_servers_until_idle(
occ-000707	slime/backends/sglang_utils/server_control.py:245 · 快照	abort_servers_until_idle	await	await	python_ast	results = await asyncio.gather(
occ-000808	slime/data/queue_data_source.py:1113 · 快照	QueueReader	async_def	get_samples_async	python_ast	async def get_samples_async(self, num_samples):
occ-000809	slime/data/queue_data_source.py:1115 · 快照	QueueReader.get_samples_async	await	await	python_ast	return await asyncio.get_running_loop().run_in_executor(self._reader, self.get_samples, num_samples)
occ-000831	slime/data/transport.py:364 · 快照	<module>	async_def	publish_rollout_async	python_ast	async def publish_rollout_async(value, args, rollout_id, *, group=False, controller=None):
occ-000832	slime/data/transport.py:366 · 快照	publish_rollout_async	await	await	python_ast	return await run_rollout_io(args, pack_rollout_group, value, args, rollout_id, controller=controller)
occ-000833	slime/data/transport.py:367 · 快照	publish_rollout_async	await	await	python_ast	return await run_rollout_io(args, pack_rollout_payload, value, args, rollout_id)
occ-000834	slime/data/transport.py:370 · 快照	<module>	async_def	run_rollout_io	python_ast	async def run_rollout_io(args, function, values, *kwargs):
occ-000838	slime/data/transport.py:376 · 快照	run_rollout_io	async_with	async with	python_ast	async with _async_limits[key]:
occ-000841	slime/data/transport.py:379 · 快照	run_rollout_io	await	await	python_ast	return await asyncio.shield(pending)
occ-000845	slime/data/transport.py:385 · 快照	run_rollout_io	await	await	python_ast	await asyncio.shield(pending)
occ-000849	slime/data/transport.py:410 · 快照	<module>	async_def	unpack_published_payload	python_ast	async def unpack_published_payload(value):
occ-000850	slime/data/transport.py:413 · 快照	unpack_published_payload	await	await	python_ast	return await asyncio.to_thread(unpack_rollout_payload, value)
occ-000852	slime/data/transport.py:419 · 快照	unpack_published_payload	await	await	python_ast	return await asyncio.to_thread(unpack_rollout_payload, value)
occ-000885	slime/observability/trace_utils.py:463 · 快照	trace_function.decorator	async_def	async_wrapper	python_ast	async def async_wrapper(args, *kwargs):
occ-000886	slime/observability/trace_utils.py:472 · 快照	trace_function.decorator.async_wrapper	await	await	python_ast	return await fn(args, *kwargs)
occ-000887	slime/observability/trace_utils.py:475 · 快照	trace_function.decorator.async_wrapper	await	await	python_ast	return await fn(args, *kwargs)
occ-000935	slime/rollout/fully_async_distributed.py:279 · 快照	_GenerationActor	async_def	start	python_ast	async def start(self, rollout_id):
occ-000937	slime/rollout/fully_async_distributed.py:281 · 快照	_GenerationActor.start	await	await	python_ast	await asyncio.wrap_future(future)
occ-000939	slime/rollout/fully_async_distributed.py:283 · 快照	_GenerationActor	async_def	_start	python_ast	async def _start(self, rollout_id):
occ-000944	slime/rollout/fully_async_distributed.py:294 · 快照	_GenerationActor	async_def	pause	python_ast	async def pause(self):
occ-000946	slime/rollout/fully_async_distributed.py:296 · 快照	_GenerationActor.pause	await	await	python_ast	await asyncio.wrap_future(future)
occ-000948	slime/rollout/fully_async_distributed.py:298 · 快照	_GenerationActor	async_def	_pause	python_ast	async def _pause(self):
occ-000949	slime/rollout/fully_async_distributed.py:301 · 快照	_GenerationActor	async_def	next	python_ast	async def next(self):
occ-000951	slime/rollout/fully_async_distributed.py:303 · 快照	_GenerationActor.next	await	await	python_ast	return await asyncio.wrap_future(future)
occ-000953	slime/rollout/fully_async_distributed.py:305 · 快照	_GenerationActor	async_def	_next	python_ast	async def _next(self):
occ-000956	slime/rollout/fully_async_distributed.py:308 · 快照	_GenerationActor._next	await	await	python_ast	await asyncio.wait((take, self.producer), return_when=asyncio.FIRST_COMPLETED)
occ-000963	slime/rollout/fully_async_distributed.py:313 · 快照	_GenerationActor._next	await	await	python_ast	return await take
occ-000965	slime/rollout/fully_async_distributed.py:317 · 快照	_GenerationActor._next	await	await	python_ast	await asyncio.gather(take, return_exceptions=True)
occ-000967	slime/rollout/fully_async_distributed.py:319 · 快照	_GenerationActor	async_def	_produce	python_ast	async def _produce(self):
occ-000968	slime/rollout/fully_async_distributed.py:320 · 快照	_GenerationActor._produce	async_def	generate_slot	python_ast	async def generate_slot(group):
occ-000969	slime/rollout/fully_async_distributed.py:322 · 快照	_GenerationActor._produce.generate_slot	await	await	python_ast	output = await self._generate_group(self.rollout_id, group)
occ-000970	slime/rollout/fully_async_distributed.py:325 · 快照	_GenerationActor._produce.generate_slot	await	await	python_ast	await self.outputs.put(output)
occ-000972	slime/rollout/fully_async_distributed.py:333 · 快照	_GenerationActor._produce	await	await	python_ast	groups = await self.data_source.get_samples_async(min(64, self.capacity - offset))
occ-000974	slime/rollout/fully_async_distributed.py:337 · 快照	_GenerationActor._produce	await	await	python_ast	await asyncio.sleep(0.001)
occ-000976	slime/rollout/fully_async_distributed.py:338 · 快照	_GenerationActor._produce	await	await	python_ast	await asyncio.gather(*tasks)
occ-000979	slime/rollout/fully_async_distributed.py:342 · 快照	_GenerationActor._produce	await	await	python_ast	await asyncio.gather(*tasks, return_exceptions=True)
occ-000981	slime/rollout/fully_async_distributed.py:344 · 快照	_GenerationActor	async_def	_generate_group	python_ast	async def _generate_group(self, rollout_id, group=None):
occ-000982	slime/rollout/fully_async_distributed.py:348 · 快照	_GenerationActor._generate_group	await	await	python_ast	group = (await self.data_source.get_samples_async(1))[0]
occ-000983	slime/rollout/fully_async_distributed.py:352 · 快照	_GenerationActor._generate_group	await	await	python_ast	await self._rebuffer(group)
occ-000984	slime/rollout/fully_async_distributed.py:360 · 快照	_GenerationActor._generate_group	await	await	python_ast	group = await generate_and_rm_group(self.args, group, self.state.sampling_params.copy())
occ-000985	slime/rollout/fully_async_distributed.py:364 · 快照	_GenerationActor._generate_group	await	await	python_ast	await self._rebuffer(group)
occ-000986	slime/rollout/fully_async_distributed.py:373 · 快照	_GenerationActor._generate_group	await	await	python_ast	await asyncio.to_thread(
occ-000988	slime/rollout/fully_async_distributed.py:382 · 快照	_GenerationActor._generate_group	await	await	python_ast	group = await publish_rollout_async(
occ-000989	slime/rollout/fully_async_distributed.py:387 · 快照	_GenerationActor._generate_group	await	await	python_ast	accepted = await publish_rollout_async(
occ-000990	slime/rollout/fully_async_distributed.py:394 · 快照	_GenerationActor._generate_group	await	await	python_ast	group = await asyncio.to_thread(self.data_source.materialize_samples, group)
occ-000992	slime/rollout/fully_async_distributed.py:397 · 快照	_GenerationActor	async_def	_rebuffer	python_ast	async def _rebuffer(self, group):
occ-000996	slime/rollout/fully_async_distributed.py:405 · 快照	_GenerationActor._rebuffer	await	await	python_ast	await asyncio.shield(future)
occ-000998	slime/rollout/fully_async_distributed.py:407 · 快照	_GenerationActor	async_def	_flush_rebuffers	python_ast	async def _flush_rebuffers(self):
occ-000999	slime/rollout/fully_async_distributed.py:409 · 快照	_GenerationActor._flush_rebuffers	await	await	python_ast	await asyncio.sleep(0.01)
occ-001001	slime/rollout/fully_async_distributed.py:413 · 快照	_GenerationActor._flush_rebuffers	await	await	python_ast	await asyncio.to_thread(self.data_source.add_samples, [group for group, _ in batch])
occ-001007	slime/rollout/fully_async_distributed.py:434 · 快照	_GenerationActor	async_def	close	python_ast	async def close(self):
occ-001009	slime/rollout/fully_async_distributed.py:436 · 快照	_GenerationActor.close	await	await	python_ast	await asyncio.wrap_future(future)
occ-001011	slime/rollout/fully_async_distributed.py:438 · 快照	_GenerationActor	async_def	_close	python_ast	async def _close(self):
occ-001013	slime/rollout/fully_async_distributed.py:442 · 快照	_GenerationActor._close	await	await	python_ast	await asyncio.gather(self.producer, return_exceptions=True)
occ-001015	slime/rollout/fully_async_distributed.py:444 · 快照	_GenerationActor._close	await	await	python_ast	await self._rebuffer_task
occ-001016	slime/rollout/fully_async_distributed.py:447 · 快照	_GenerationActor._close	await	await	python_ast	await asyncio.get_running_loop().shutdown_default_executor()
occ-001043	slime/rollout/fully_async_rollout.py:173 · 快照	AsyncRolloutWorker	async_def	_loop	python_ast	async def _loop(self) -> None:
occ-001047	slime/rollout/fully_async_rollout.py:192 · 快照	AsyncRolloutWorker._loop	await	await	python_ast	await asyncio.sleep(0)
occ-001053	slime/rollout/fully_async_rollout.py:226 · 快照	AsyncRolloutWorker._loop	await	await	python_ast	await asyncio.sleep(self.poll_interval)
occ-001055	slime/rollout/fully_async_rollout.py:237 · 快照	AsyncRolloutWorker._loop	await	await	python_ast	await asyncio.wait(active_tasks, timeout=30)
occ-001062	slime/rollout/fully_async_rollout.py:268 · 快照	<module>	async_def	_generate_rollout_async	python_ast	async def _generate_rollout_async(args, rollout_id: int, data_buffer) -> RolloutFnTrainOutput \| list[list[Sample]]:
occ-001063	slime/rollout/fully_async_rollout.py:306 · 快照	_generate_rollout_async	await	await	python_ast	group = await publish_rollout_async(
occ-001064	slime/rollout/fully_async_rollout.py:312 · 快照	_generate_rollout_async	await	await	python_ast	await asyncio.to_thread(
occ-001067	slime/rollout/fully_async_rollout.py:324 · 快照	_generate_rollout_async	await	await	python_ast	await asyncio.sleep(0.05)
occ-001069	slime/rollout/fully_async_rollout.py:357 · 快照	_generate_rollout_async	await	await	python_ast	output = await asyncio.to_thread(
occ-001071	slime/rollout/on_policy_distillation.py:8 · 快照	<module>	async_def	reward_func	python_ast	async def reward_func(args, sample, **kwargs):
occ-001073	slime/rollout/on_policy_distillation.py:26 · 快照	reward_func	async_with	async with	python_ast	async with aiohttp.ClientSession(**session_kwargs) as session:
occ-001074	slime/rollout/on_policy_distillation.py:27 · 快照	reward_func	async_with	async with	python_ast	async with session.post(args.rm_url, json=payload) as resp:
occ-001075	slime/rollout/on_policy_distillation.py:29 · 快照	reward_func	await	await	python_ast	return await resp.json()
occ-001077	slime/rollout/rm_hub/init.py:34 · 快照	<module>	async_def	remote_rm	python_ast	async def remote_rm(args, sample: Sample, max_retries: int = 10):
occ-001078	slime/rollout/rm_hub/init.py:43 · 快照	remote_rm	async_with	async with	python_ast	async with session.post(args.rm_url, json=payload) as resp:
occ-001079	slime/rollout/rm_hub/init.py:45 · 快照	remote_rm	await	await	python_ast	return await resp.json()
occ-001080	slime/rollout/rm_hub/init.py:52 · 快照	remote_rm	await	await	python_ast	await asyncio.sleep(backoff)
occ-001082	slime/rollout/rm_hub/init.py:55 · 快照	<module>	async_def	async_rm	python_ast	async def async_rm(args, sample: Sample, **kwargs):
occ-001083	slime/rollout/rm_hub/init.py:59 · 快照	async_rm	await	await	python_ast	return await rm_function(args, sample, **kwargs)
occ-001084	slime/rollout/rm_hub/init.py:63 · 快照	async_rm	await	await	python_ast	return await rm_function(args, sample, **kwargs)
occ-001086	slime/rollout/rm_hub/init.py:76 · 快照	async_rm	await	await	python_ast	return await remote_rm(args, sample)
occ-001087	slime/rollout/rm_hub/init.py:99 · 快照	<module>	async_def	batched_async_rm	python_ast	async def batched_async_rm(
occ-001088	slime/rollout/rm_hub/init.py:107 · 快照	batched_async_rm	await	await	python_ast	return await rm_function(args, samples, **kwargs)
occ-001089	slime/rollout/rm_hub/init.py:109 · 快照	batched_async_rm	await	await	python_ast	rewards = await asyncio.gather(*tasks)
occ-001108	slime/rollout/sample_hooks.py:37 · 快照	<module>	async_def	_apply_to_sample	python_ast	async def _apply_to_sample(args, sample: Sample, paths: list[str], **kwargs) -> Sample:
occ-001110	slime/rollout/sample_hooks.py:42 · 快照	_apply_to_sample	await	await	python_ast	result = await result
occ-001111	slime/rollout/sample_hooks.py:52 · 快照	<module>	async_def	apply_rollout_sample_hooks	python_ast	async def apply_rollout_sample_hooks(args, value, **kwargs):
occ-001113	slime/rollout/sample_hooks.py:61 · 快照	apply_rollout_sample_hooks	await	await	python_ast	return await _apply_to_sample(args, value, paths, **kwargs)
occ-001114	slime/rollout/sample_hooks.py:63 · 快照	apply_rollout_sample_hooks.<comprehension>	await	await	python_ast	return [await apply_rollout_sample_hooks(args, item, **kwargs) for item in value]
occ-001120	slime/rollout/sglang_rollout.py:158 · 快照	<module>	async_def	generate	python_ast	async def generate(args: Namespace, sample: Sample, sampling_params: dict[str, Any]) -> Sample:
occ-001122	slime/rollout/sglang_rollout.py:220 · 快照	generate	await	await	python_ast	output = await post(
occ-001123	slime/rollout/sglang_rollout.py:258 · 快照	<module>	async_def	_run_request_abortable_generate	python_ast	async def _run_request_abortable_generate(
occ-001126	slime/rollout/sglang_rollout.py:267 · 快照	_run_request_abortable_generate	await	await	python_ast	return await generate_call
occ-001128	slime/rollout/sglang_rollout.py:277 · 快照	<module>	async_def	_run_server_abort_generate	python_ast	async def _run_server_abort_generate(
occ-001130	slime/rollout/sglang_rollout.py:283 · 快照	_run_server_abort_generate	await	await	python_ast	return await generate_call
occ-001131	slime/rollout/sglang_rollout.py:289 · 快照	<module>	async_def	generate_and_rm	python_ast	async def generate_and_rm(
occ-001132	slime/rollout/sglang_rollout.py:329 · 快照	generate_and_rm	async_with	async with	python_ast	async with state.semaphore:
occ-001133	slime/rollout/sglang_rollout.py:330 · 快照	generate_and_rm	await	await	python_ast	await state.generation_pacer.wait()
occ-001135	slime/rollout/sglang_rollout.py:345 · 快照	generate_and_rm	await	await	python_ast	sample = await _run_request_abortable_generate(state, sample, generate_call)
occ-001136	slime/rollout/sglang_rollout.py:347 · 快照	generate_and_rm	await	await	python_ast	sample = await _run_server_abort_generate(state, generate_call)
occ-001137	slime/rollout/sglang_rollout.py:350 · 快照	generate_and_rm	await	await	python_ast	sample = await apply_rollout_sample_hooks(args, sample, evaluation=evaluation)
occ-001138	slime/rollout/sglang_rollout.py:364 · 快照	generate_and_rm	await	await	python_ast	rewards = await batched_async_rm(args, samples_need_reward)
occ-001139	slime/rollout/sglang_rollout.py:374 · 快照	generate_and_rm	await	await	python_ast	sample.reward = await async_rm(args, sample)
occ-001140	slime/rollout/sglang_rollout.py:384 · 快照	<module>	async_def	generate_and_rm_group	python_ast	async def generate_and_rm_group(
occ-001142	slime/rollout/sglang_rollout.py:414 · 快照	generate_and_rm_group	await	await	python_ast	group = await asyncio.gather(*tasks)
occ-001144	slime/rollout/sglang_rollout.py:419 · 快照	generate_and_rm_group	await	await	python_ast	rewards = await batched_async_rm(args, group)
occ-001145	slime/rollout/sglang_rollout.py:426 · 快照	<module>	async_def	abort	python_ast	async def abort(args: Namespace, rollout_id: int) -> list[list[Sample]]:
occ-001147	slime/rollout/sglang_rollout.py:441 · 快照	abort	await	await	python_ast	workers = (await get(f"{router_url}/workers"))[“workers”]
occ-001148	slime/rollout/sglang_rollout.py:445 · 快照	abort	await	await	python_ast	workers = await get_live_router_workers(router_url, timeout=args.rollout_health_check_timeout)
occ-001149	slime/rollout/sglang_rollout.py:447 · 快照	abort	await	await	python_ast	await abort_servers_until_idle(urls)
occ-001150	slime/rollout/sglang_rollout.py:449 · 快照	abort	await	await	python_ast	await asyncio.gather(*cancellable_tasks, return_exceptions=True)
occ-001152	slime/rollout/sglang_rollout.py:454 · 快照	abort	await	await	python_ast	done, state.pendings = await asyncio.wait(state.pendings, return_when=asyncio.FIRST_COMPLETED)
occ-001156	slime/rollout/sglang_rollout.py:476 · 快照	<module>	async_def	generate_rollout_async	python_ast	async def generate_rollout_async(
occ-001157	slime/rollout/sglang_rollout.py:517 · 快照	generate_rollout_async	await	await	python_ast	samples = await reader.get_samples_async(args.over_sampling_batch_size)
occ-001158	slime/rollout/sglang_rollout.py:523 · 快照	generate_rollout_async	await	await	python_ast	done, state.pendings = await asyncio.wait(state.pendings, return_when=asyncio.FIRST_COMPLETED)
occ-001162	slime/rollout/sglang_rollout.py:545 · 快照	generate_rollout_async	await	await	python_ast	await asyncio.to_thread(
occ-001164	slime/rollout/sglang_rollout.py:561 · 快照	generate_rollout_async	await	await	python_ast	group = await publish_rollout_async(group, args, rollout_id, group=True, controller=controller)
occ-001166	slime/rollout/sglang_rollout.py:571 · 快照	generate_rollout_async	await	await	python_ast	aborted_samples = await abort(args, rollout_id)
occ-001168	slime/rollout/sglang_rollout.py:585 · 快照	generate_rollout_async.<comprehension>	await	await	python_ast	await publish_rollout_async(group, args, rollout_id, group=True, controller=controller)
occ-001169	slime/rollout/sglang_rollout.py:588 · 快照	generate_rollout_async	await	await	python_ast	data = await publish_rollout_async(data, args, rollout_id)
occ-001170	slime/rollout/sglang_rollout.py:594 · 快照	generate_rollout_async	await	await	python_ast	output = await asyncio.to_thread(
occ-001172	slime/rollout/sglang_rollout.py:603 · 快照	<module>	async_def	eval_rollout	python_ast	async def eval_rollout(args: Namespace, rollout_id: int) -> tuple[dict[str, dict[str, list[Any]]], list[list[Sample]]]:
occ-001173	slime/rollout/sglang_rollout.py:609 · 快照	eval_rollout	await	await	python_ast	results_list = await asyncio.gather(*coros)
occ-001175	slime/rollout/sglang_rollout.py:616 · 快照	<module>	async_def	eval_rollout_single_dataset	python_ast	async def eval_rollout_single_dataset(
occ-001178	slime/rollout/sglang_rollout.py:726 · 快照	eval_rollout_single_dataset	await	await	python_ast	sample = await coro
occ-001180	slime/rollout/sglang_streaming_rollout.py:48 · 快照	<module>	async_def	generate_streaming	python_ast	async def generate_streaming(args: Namespace, sample: Sample, sampling_params: dict[str, Any]) -> Sample:
occ-001182	slime/rollout/sglang_streaming_rollout.py:125 · 快照	generate_streaming	async_with	async with	python_ast	async with client.stream(“POST”, url, json=payload, headers=headers) as response:
occ-001183	slime/rollout/sglang_streaming_rollout.py:127 · 快照	generate_streaming	async_for	async for	python_ast	async for raw_line in response.aiter_lines():
occ-001198	slime/utils/async_utils.py:24 · 快照	AsyncPacer	async_def	wait	python_ast	async def wait(self):
occ-001202	slime/utils/async_utils.py:31 · 快照	AsyncPacer.wait	await	await	python_ast	await future
occ-001248	slime/utils/http_utils.py:180 · 快照	_ShardedHTTPTransport	async_def	handle_async_request	python_ast	async def handle_async_request(self, request):
occ-001249	slime/utils/http_utils.py:183 · 快照	_ShardedHTTPTransport.handle_async_request	await	await	python_ast	return await transport.handle_async_request(request)
occ-001250	slime/utils/http_utils.py:185 · 快照	_ShardedHTTPTransport	async_def	aclose	python_ast	async def aclose(self):
occ-001251	slime/utils/http_utils.py:186 · 快照	_ShardedHTTPTransport.aclose	await	await	python_ast	await asyncio.gather(*(transport.aclose() for transport in self._transports))
occ-001253	slime/utils/http_utils.py:189 · 快照	<module>	async_def	_post	python_ast	async def _post(client, url, payload, max_retries=60, headers=None, timeout=None, score_centering_top_k=None):
occ-001254	slime/utils/http_utils.py:197 · 快照	_post	await	await	python_ast	response = await client.post(url, **request_kwargs)
occ-001255	slime/utils/http_utils.py:199 · 快照	_post	await	await	python_ast	content = await response.aread()
occ-001256	slime/utils/http_utils.py:204 · 快照	_post	await	await	python_ast	output = await asyncio.to_thread(decode_score_centering_response, content, score_centering_top_k)
occ-001258	slime/utils/http_utils.py:223 · 快照	_post	await	await	python_ast	await asyncio.sleep(1)
occ-001260	slime/utils/http_utils.py:227 · 快照	_post	await	await	python_ast	await response.aclose()
occ-001262	slime/utils/http_utils.py:297 · 快照	_init_ray_distributed_post._HttpPosterActor	async_def	do_post	python_ast	async def do_post(self, url, payload, max_retries=60, headers=None, timeout=None, score_centering_top_k=None):
occ-001263	slime/utils/http_utils.py:298 · 快照	_init_ray_distributed_post._HttpPosterActor.do_post	await	await	python_ast	return await _post(
occ-001264	slime/utils/http_utils.py:331 · 快照	<module>	async_def	post	python_ast	async def post(url, payload, max_retries=60, headers=None, timeout=None, score_centering_top_k=None):
occ-001265	slime/utils/http_utils.py:351 · 快照	post	await	await	python_ast	return await obj_ref
occ-001266	slime/utils/http_utils.py:356 · 快照	post	await	await	python_ast	return await _post(
occ-001267	slime/utils/http_utils.py:367 · 快照	<module>	async_def	get	python_ast	async def get(url, *, timeout=None):
occ-001268	slime/utils/http_utils.py:368 · 快照	get	await	await	python_ast	response = await _http_client.get(url, timeout=timeout)
occ-001270	slime/utils/http_utils.py:371 · 快照	get	await	await	python_ast	content = await response.aread()
occ-001271	slime/utils/http_utils.py:374 · 快照	get	await	await	python_ast	await response.aclose()
occ-001312	slime_plugins/rollout_buffer/buffer.py:113 · 快照	<module>	async_def	set_body_size	python_ast	async def set_body_size(request: Request, call_next):
occ-001313	slime_plugins/rollout_buffer/buffer.py:115 · 快照	set_body_size	await	await	python_ast	response = await call_next(request)
occ-001318	slime_plugins/rollout_buffer/buffer.py:260 · 快照	<module>	async_def	write_to_buffer	python_ast	async def write_to_buffer(request: Request):
occ-001319	slime_plugins/rollout_buffer/buffer.py:262 · 快照	write_to_buffer	await	await	python_ast	data = await request.json()
occ-001321	slime_plugins/rollout_buffer/buffer.py:278 · 快照	<module>	async_def	get_rollout_data	python_ast	async def get_rollout_data(request: Request):
occ-001326	slime_plugins/rollout_buffer/buffer.py:326 · 快照	<module>	async_def	start_rollout	python_ast	async def start_rollout(request: Request, background: BackgroundTasks):
occ-001327	slime_plugins/rollout_buffer/buffer.py:327 · 快照	start_rollout	await	await	python_ast	payload = await request.json()
occ-001352	slime_plugins/rollout_buffer/rollout_buffer_example.py:138 · 快照	<module>	async_def	get_rollout_data	python_ast	async def get_rollout_data(api_base_url: str) -> tuple[list[dict[str, Any]], dict[str, Any]]:
occ-001353	slime_plugins/rollout_buffer/rollout_buffer_example.py:140 · 快照	get_rollout_data	async_with	async with	python_ast	async with aiohttp.ClientSession() as session:
occ-001354	slime_plugins/rollout_buffer/rollout_buffer_example.py:142 · 快照	get_rollout_data	async_with	async with	python_ast	async with session.post(
occ-001355	slime_plugins/rollout_buffer/rollout_buffer_example.py:146 · 快照	get_rollout_data	await	await	python_ast	resp_json = await response.json()
occ-001356	slime_plugins/rollout_buffer/rollout_buffer_example.py:149 · 快照	get_rollout_data	await	await	python_ast	await asyncio.sleep(3)
occ-001358	slime_plugins/rollout_buffer/rollout_buffer_example.py:207 · 快照	<module>	async_def	generate_rollout_async	python_ast	async def generate_rollout_async(args, rollout_id: int, data_buffer, evaluation: bool = False) -> dict[str, Any]:
occ-001360	slime_plugins/rollout_buffer/rollout_buffer_example.py:244 · 快照	generate_rollout_async	await	await	python_ast	data, meta_info = await get_rollout_data(api_base_url=base_url)
occ-001401	tests/fanout_test_helpers.py:39 · 快照	<module>	async_def	compact_generate	python_ast	async def compact_generate(args, sample, sampling_params):
occ-001403	tests/fanout_test_helpers.py:57 · 快照	compact_generate	await	await	python_ast	base_sample = await generate(args, sample, sampling_params)
occ-001406	tests/pipeline_rl_test_helpers.py:21 · 快照	<module>	async_def	reward	python_ast	async def reward(args, sample, **kwargs):
occ-001427	tests/plugin_contracts/test_plugin_generate_contracts.py:75 · 快照	<module>	async_def	custom_generate	python_ast	async def custom_generate(args, sample: Sample, sampling_params: dict):
occ-001428	tests/plugin_contracts/test_plugin_generate_contracts.py:84 · 快照	<module>	async_def	custom_generate_with_evaluation	python_ast	async def custom_generate_with_evaluation(args, sample: Sample, sampling_params: dict, evaluation: bool = False):
occ-001429	tests/plugin_contracts/test_plugin_generate_contracts.py:108 · 快照	_DummySemaphore	async_def	aenter	python_ast	async def aenter(self):
occ-001430	tests/plugin_contracts/test_plugin_generate_contracts.py:111 · 快照	_DummySemaphore	async_def	aexit	python_ast	async def aexit(self, exc_type, exc, tb):
occ-001431	tests/plugin_contracts/test_plugin_generate_contracts.py:133 · 快照	test_generate_and_rm_default_generate_branch_is_stable	async_def	official_default_generate	python_ast	async def official_default_generate(args, sample: Sample, sampling_params: dict):
occ-001435	tests/plugin_contracts/test_plugin_generate_contracts.py:183 · 快照	test_generate_and_rm_group_rm_accepts_list_result_from_custom_generate	async_def	custom_generate_list	python_ast	async def custom_generate_list(args, sample: Sample, sampling_params: dict):
occ-001439	tests/plugin_contracts/test_plugin_path_loading_contracts.py:143 · 快照	<module>	async_def	reference_single_rm	python_ast	async def reference_single_rm(args, sample: Sample, **kwargs):
occ-001440	tests/plugin_contracts/test_plugin_path_loading_contracts.py:147 · 快照	<module>	async_def	reference_batched_rm	python_ast	async def reference_batched_rm(args, samples: list[Sample], **kwargs):
occ-001445	tests/rollout_health_test_helpers.py:15 · 快照	<module>	async_def	reward	python_ast	async def reward(args, sample, **kwargs):
occ-001446	tests/rollout_health_test_helpers.py:36 · 快照	generate_rollout	async_def	crash_then_abort	python_ast	async def crash_then_abort(config, current_rollout):
occ-001447	tests/rollout_health_test_helpers.py:48 · 快照	generate_rollout.crash_then_abort	await	await	python_ast	result = await original_abort(config, current_rollout)
occ-001461	tests/test_agent/_fakes.py:157 · 快照	FakeSGLangServer	async_def	_handle	python_ast	async def _handle(self, request: web.Request) -> web.Response:
occ-001463	tests/test_agent/_fakes.py:159 · 快照	FakeSGLangServer._handle	await	await	python_ast	self.requests.append(await request.json())
occ-001464	tests/test_agent/_fakes.py:171 · 快照	FakeSGLangServer	async_def	aenter	python_ast	async def aenter(self) -> FakeSGLangServer:
occ-001465	tests/test_agent/_fakes.py:177 · 快照	FakeSGLangServer.aenter	await	await	python_ast	await self._server.start_server()
occ-001466	tests/test_agent/_fakes.py:181 · 快照	FakeSGLangServer	async_def	aexit	python_ast	async def aexit(self, *exc) -> None:
occ-001467	tests/test_agent/_fakes.py:183 · 快照	FakeSGLangServer.aexit	await	await	python_ast	await self._server.close()
occ-001469	tests/test_agent/_fakes.py:197 · 快照	fake_call_sglang_generate	async_def	_fake	python_ast	async def _fake(prompt_ids, session, body, *, adapter, session_id=None) -> TurnRecord:
occ-001471	tests/test_agent/_fakes.py:260 · 快照	FakeSandbox	async_def	aenter	python_ast	async def aenter(self) -> FakeSandbox:
occ-001472	tests/test_agent/_fakes.py:263 · 快照	FakeSandbox	async_def	aexit	python_ast	async def aexit(self, *exc) -> None:
occ-001473	tests/test_agent/_fakes.py:266 · 快照	FakeSandbox	async_def	exec	python_ast	async def exec(self, cmd, *, user=“root”, env=None, timeout=120, check=False, idempotent=True):
occ-001474	tests/test_agent/_fakes.py:271 · 快照	FakeSandbox.exec	await	await	python_ast	code = await self.on_launch(env or {})
occ-001475	tests/test_agent/_fakes.py:290 · 快照	FakeSandbox	async_def	write_file	python_ast	async def write_file(self, sandbox_path, content, *, user=“root”) -> None:
occ-001476	tests/test_agent/_fakes.py:293 · 快照	FakeSandbox	async_def	read_file	python_ast	async def read_file(self, sandbox_path, *, user=“root”) -> str:
occ-001480	tests/test_agent/test_adapters.py:73 · 快照	<module>	async_def	_drain	python_ast	async def _drain(adapter, sid) -> list[Sample]:
occ-001481	tests/test_agent/test_adapters.py:74 · 快照	_drain	await	await	python_ast	return await adapter.finish_session(sid, base_sample=Sample(index=0, prompt=""), reward=1.0)
occ-001482	tests/test_agent/test_adapters.py:169 · 快照	test_anthropic_messages_nonstream_records_token_segments	async_def	run_case	python_ast	async def run_case():
occ-001483	tests/test_agent/test_adapters.py:170 · 快照	test_anthropic_messages_nonstream_records_token_segments.run_case	async_with	async with	python_ast	async with FakeSGLangServer([[(-0.1, 101), (-0.2, 102)]]) as sglang:
occ-001484	tests/test_agent/test_adapters.py:175 · 快照	test_anthropic_messages_nonstream_records_token_segments.run_case	await	await	python_ast	await client.start_server()
occ-001485	tests/test_agent/test_adapters.py:177 · 快照	test_anthropic_messages_nonstream_records_token_segments.run_case	await	await	python_ast	resp = await client.post(
occ-001486	tests/test_agent/test_adapters.py:182 · 快照	test_anthropic_messages_nonstream_records_token_segments.run_case	await	await	python_ast	data = await resp.json()
occ-001487	tests/test_agent/test_adapters.py:184 · 快照	test_anthropic_messages_nonstream_records_token_segments.run_case	await	await	python_ast	await client.close()
occ-001489	tests/test_agent/test_adapters.py:185 · 快照	test_anthropic_messages_nonstream_records_token_segments.run_case	await	await	python_ast	samples = await _drain(adapter, “sid-a”)
occ-001491	tests/test_agent/test_adapters.py:205 · 快照	test_openai_chat_completions_nonstream_records_token_segments	async_def	run_case	python_ast	async def run_case():
occ-001492	tests/test_agent/test_adapters.py:206 · 快照	test_openai_chat_completions_nonstream_records_token_segments.run_case	async_with	async with	python_ast	async with FakeSGLangServer([[(-0.3, 201)]]) as sglang:
occ-001493	tests/test_agent/test_adapters.py:211 · 快照	test_openai_chat_completions_nonstream_records_token_segments.run_case	await	await	python_ast	await client.start_server()
occ-001494	tests/test_agent/test_adapters.py:213 · 快照	test_openai_chat_completions_nonstream_records_token_segments.run_case	await	await	python_ast	resp = await client.post(
occ-001495	tests/test_agent/test_adapters.py:218 · 快照	test_openai_chat_completions_nonstream_records_token_segments.run_case	await	await	python_ast	data = await resp.json()
occ-001496	tests/test_agent/test_adapters.py:220 · 快照	test_openai_chat_completions_nonstream_records_token_segments.run_case	await	await	python_ast	await client.close()
occ-001498	tests/test_agent/test_adapters.py:221 · 快照	test_openai_chat_completions_nonstream_records_token_segments.run_case	await	await	python_ast	samples = await _drain(adapter, “sid-o”)
occ-001500	tests/test_agent/test_adapters.py:239 · 快照	test_anthropic_messages_streams_blocks	async_def	run_case	python_ast	async def run_case():
occ-001501	tests/test_agent/test_adapters.py:240 · 快照	test_anthropic_messages_streams_blocks.run_case	async_with	async with	python_ast	async with FakeSGLangServer([[(-0.1, 301)]]) as sglang:
occ-001502	tests/test_agent/test_adapters.py:245 · 快照	test_anthropic_messages_streams_blocks.run_case	await	await	python_ast	await client.start_server()
occ-001503	tests/test_agent/test_adapters.py:247 · 快照	test_anthropic_messages_streams_blocks.run_case	await	await	python_ast	resp = await client.post(
occ-001504	tests/test_agent/test_adapters.py:257 · 快照	test_anthropic_messages_streams_blocks.run_case	await	await	python_ast	raw = await resp.text()
occ-001505	tests/test_agent/test_adapters.py:259 · 快照	test_anthropic_messages_streams_blocks.run_case	await	await	python_ast	await client.close()
occ-001507	tests/test_agent/test_adapters.py:260 · 快照	test_anthropic_messages_streams_blocks.run_case	await	await	python_ast	await _drain(adapter, “sid-as”)
occ-001510	tests/test_agent/test_adapters.py:273 · 快照	test_openai_chat_completions_streams_chunks_until_done	async_def	run_case	python_ast	async def run_case():
occ-001511	tests/test_agent/test_adapters.py:274 · 快照	test_openai_chat_completions_streams_chunks_until_done.run_case	async_with	async with	python_ast	async with FakeSGLangServer([[(-0.1, 401)]]) as sglang:
occ-001512	tests/test_agent/test_adapters.py:279 · 快照	test_openai_chat_completions_streams_chunks_until_done.run_case	await	await	python_ast	await client.start_server()
occ-001513	tests/test_agent/test_adapters.py:281 · 快照	test_openai_chat_completions_streams_chunks_until_done.run_case	await	await	python_ast	resp = await client.post(
occ-001514	tests/test_agent/test_adapters.py:286 · 快照	test_openai_chat_completions_streams_chunks_until_done.run_case	await	await	python_ast	raw = await resp.text()
occ-001515	tests/test_agent/test_adapters.py:288 · 快照	test_openai_chat_completions_streams_chunks_until_done.run_case	await	await	python_ast	await client.close()
occ-001517	tests/test_agent/test_adapters.py:289 · 快照	test_openai_chat_completions_streams_chunks_until_done.run_case	await	await	python_ast	await _drain(adapter, “sid-os”)
occ-001519	tests/test_agent/test_adapters.py:313 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture	async_def	run_case	python_ast	async def run_case():
occ-001520	tests/test_agent/test_adapters.py:315 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	async_with	async with	python_ast	async with FakeSGLangServer([[(-0.5, 700), (-0.5, 701)], [(-0.4, 800)]]) as sglang:
occ-001521	tests/test_agent/test_adapters.py:320 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	await	await	python_ast	await client.start_server()
occ-001522	tests/test_agent/test_adapters.py:325 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	await	await	python_ast	first = await client.post(
occ-001523	tests/test_agent/test_adapters.py:335 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	await	await	python_ast	fdata = await first.json()
occ-001524	tests/test_agent/test_adapters.py:337 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	await	await	python_ast	second = await client.post(
occ-001525	tests/test_agent/test_adapters.py:356 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	await	await	python_ast	await second.json()
occ-001526	tests/test_agent/test_adapters.py:358 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	await	await	python_ast	await client.close()
occ-001528	tests/test_agent/test_adapters.py:359 · 快照	test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_case	await	await	python_ast	samples = await _drain(adapter, “sid-mt”)
occ-001530	tests/test_agent/test_adapters.py:384 · 快照	test_max_turns_per_sid_returns_429	async_def	run_case	python_ast	async def run_case():
occ-001531	tests/test_agent/test_adapters.py:385 · 快照	test_max_turns_per_sid_returns_429.run_case	async_with	async with	python_ast	async with FakeSGLangServer([[(-0.1, 501)], [(-0.1, 502)]]) as sglang:
occ-001532	tests/test_agent/test_adapters.py:390 · 快照	test_max_turns_per_sid_returns_429.run_case	await	await	python_ast	await client.start_server()
occ-001533	tests/test_agent/test_adapters.py:394 · 快照	test_max_turns_per_sid_returns_429.run_case	await	await	python_ast	first = await client.post("/v1/messages", headers=h, json=body)
occ-001534	tests/test_agent/test_adapters.py:395 · 快照	test_max_turns_per_sid_returns_429.run_case	await	await	python_ast	second = await client.post("/v1/messages", headers=h, json=body)
occ-001535	tests/test_agent/test_adapters.py:397 · 快照	test_max_turns_per_sid_returns_429.run_case	await	await	python_ast	await client.close()
occ-001537	tests/test_agent/test_adapters.py:398 · 快照	test_max_turns_per_sid_returns_429.run_case	await	await	python_ast	await _drain(adapter, “sid-cap”)
occ-001544	tests/test_agent/test_agent_rollout_cpu.py:59 · 快照	<module>	async_generator_def	_timeout_shim	python_ast	async def _timeout_shim(_delay):
occ-001545	tests/test_agent/test_agent_rollout_cpu.py:60 · 快照	_timeout_shim	async_yield	yield in async generator	python_ast	yield
occ-001548	tests/test_agent/test_agent_rollout_cpu.py:81 · 快照	<module>	async_def	_fast_sleep	python_ast	async def _fast_sleep(_secs): # collapse run_command’s 5s poll loop
occ-001549	tests/test_agent/test_agent_rollout_cpu.py:82 · 快照	_fast_sleep	await	await	python_ast	await _REAL_SLEEP(0)
occ-001550	tests/test_agent/test_agent_rollout_cpu.py:108 · 快照	<module>	async_def	_anthropic_agent	python_ast	async def _anthropic_agent(env: dict, *, n_turns: int = 2) -> int:
occ-001551	tests/test_agent/test_agent_rollout_cpu.py:114 · 快照	_anthropic_agent	async_with	async with	python_ast	async with aiohttp.ClientSession(trust_env=False) as sess:
occ-001552	tests/test_agent/test_agent_rollout_cpu.py:116 · 快照	_anthropic_agent	async_with	async with	python_ast	async with sess.post(
occ-001553	tests/test_agent/test_agent_rollout_cpu.py:121 · 快照	_anthropic_agent	await	await	python_ast	data = await r.json()
occ-001554	tests/test_agent/test_agent_rollout_cpu.py:157 · 快照	<module>	async_def	_noop_install	python_ast	async def _noop_install(self, sb) -> None:
occ-001555	tests/test_agent/test_agent_rollout_cpu.py:176 · 快照	test_generate_produces_trained_samples	async_def	run_case	python_ast	async def run_case(monkeypatch):
occ-001556	tests/test_agent/test_agent_rollout_cpu.py:181 · 快照	test_generate_produces_trained_samples.run_case	await	await	python_ast	samples = await gen.generate(_args(), _base_sample(), sampling_params={“max_new_tokens”: 32})
occ-001559	tests/test_agent/test_agent_rollout_cpu.py:201 · 快照	test_generate_aborts_on_empty_trajectory	async_def	silent_agent	python_ast	async def silent_agent(_env) -> int:
occ-001560	tests/test_agent/test_agent_rollout_cpu.py:204 · 快照	test_generate_aborts_on_empty_trajectory	async_def	run_case	python_ast	async def run_case(monkeypatch):
occ-001561	tests/test_agent/test_agent_rollout_cpu.py:209 · 快照	test_generate_aborts_on_empty_trajectory.run_case	await	await	python_ast	samples = await gen.generate(_args(), _base_sample(), sampling_params={})
occ-001564	tests/test_agent/test_agent_rollout_cpu.py:220 · 快照	test_generate_aborts_on_missing_image	async_def	run_case	python_ast	async def run_case(monkeypatch):
occ-001565	tests/test_agent/test_agent_rollout_cpu.py:224 · 快照	test_generate_aborts_on_missing_image.run_case	await	await	python_ast	samples = await gen.generate(_args(), _base_sample(image=""), sampling_params={})
occ-001568	tests/test_agent/test_agent_rollout_cpu.py:238 · 快照	<module>	async_def	_codex_agent	python_ast	async def _codex_agent(env: dict, *, n_turns: int = 2) -> int:
occ-001569	tests/test_agent/test_agent_rollout_cpu.py:242 · 快照	_codex_agent	async_with	async with	python_ast	async with aiohttp.ClientSession(trust_env=False) as sess:
occ-001570	tests/test_agent/test_agent_rollout_cpu.py:244 · 快照	_codex_agent	async_with	async with	python_ast	async with sess.post(
occ-001571	tests/test_agent/test_agent_rollout_cpu.py:249 · 快照	_codex_agent	await	await	python_ast	data = await r.json()
occ-001573	tests/test_agent/test_agent_rollout_cpu.py:260 · 快照	test_codex_openai_rollout_closes_loop	async_def	run_case	python_ast	async def run_case():
occ-001574	tests/test_agent/test_agent_rollout_cpu.py:274 · 快照	test_codex_openai_rollout_closes_loop.run_case	await	await	python_ast	rc = await CodexHarness().run(
occ-001575	tests/test_agent/test_agent_rollout_cpu.py:282 · 快照	test_codex_openai_rollout_closes_loop.run_case	await	await	python_ast	samples = await adapter.finish_session(sid, base_sample=Sample(index=0, prompt=""), reward=1.0)
occ-001580	tests/test_agent/test_harness.py:38 · 快照	<module>	async_def	_fast_sleep	python_ast	async def _fast_sleep(_secs):
occ-001581	tests/test_agent/test_harness.py:39 · 快照	_fast_sleep	await	await	python_ast	await _REAL_SLEEP(0)
occ-001582	tests/test_agent/test_harness.py:56 · 快照	test_run_agent_returns_marker_exit_code	async_def	run_case	python_ast	async def run_case():
occ-001583	tests/test_agent/test_harness.py:59 · 快照	test_run_agent_returns_marker_exit_code.run_case	async_def	fake_agent	python_ast	async def fake_agent(env):
occ-001584	tests/test_agent/test_harness.py:65 · 快照	test_run_agent_returns_marker_exit_code.run_case	await	await	python_ast	rc = await hc.run_agent(
occ-001586	tests/test_agent/test_harness.py:79 · 快照	test_run_agent_propagates_nonzero_exit	async_def	run_case	python_ast	async def run_case():
occ-001587	tests/test_agent/test_harness.py:80 · 快照	test_run_agent_propagates_nonzero_exit.run_case	async_def	fail_agent	python_ast	async def fail_agent(_env):
occ-001588	tests/test_agent/test_harness.py:85 · 快照	test_run_agent_propagates_nonzero_exit.run_case	await	await	python_ast	rc = await hc.run_agent(sb, workdir="/w", start_cmd=“x”, env={}, time_budget_sec=30)
occ-001590	tests/test_agent/test_harness.py:92 · 快照	test_run_agent_times_out_when_marker_never_appears	async_def	run_case	python_ast	async def run_case():
occ-001591	tests/test_agent/test_harness.py:95 · 快照	test_run_agent_times_out_when_marker_never_appears.run_case	await	await	python_ast	rc = await hc.run_agent(sb, workdir="/w", start_cmd=“x”, env={}, time_budget_sec=0)
occ-001593	tests/test_agent/test_harness.py:107 · 快照	test_claude_code_write_config_preacks_bypass_permissions	async_def	run_case	python_ast	async def run_case():
occ-001594	tests/test_agent/test_harness.py:109 · 快照	test_claude_code_write_config_preacks_bypass_permissions.run_case	await	await	python_ast	await ClaudeCodeHarness().write_config(sb, _ctx())
occ-001597	tests/test_agent/test_harness.py:119 · 快照	test_claude_code_launch_command_and_env	async_def	run_case	python_ast	async def run_case():
occ-001598	tests/test_agent/test_harness.py:122 · 快照	test_claude_code_launch_command_and_env.run_case	async_def	agent	python_ast	async def agent(env):
occ-001599	tests/test_agent/test_harness.py:128 · 快照	test_claude_code_launch_command_and_env.run_case	await	await	python_ast	rc = await ClaudeCodeHarness().launch_and_wait(
occ-001601	tests/test_agent/test_harness.py:152 · 快照	test_codex_write_config_base64_roundtrips_inline_base_url	async_def	run_case	python_ast	async def run_case():
occ-001602	tests/test_agent/test_harness.py:154 · 快照	test_codex_write_config_base64_roundtrips_inline_base_url.run_case	await	await	python_ast	await CodexHarness().write_config(sb, _ctx(url=“http://host:18001”))
occ-001604	tests/test_agent/test_harness.py:167 · 快照	test_codex_launch_command_and_env	async_def	run_case	python_ast	async def run_case():
occ-001605	tests/test_agent/test_harness.py:170 · 快照	test_codex_launch_command_and_env.run_case	async_def	agent	python_ast	async def agent(env):
occ-001606	tests/test_agent/test_harness.py:176 · 快照	test_codex_launch_command_and_env.run_case	await	await	python_ast	rc = await CodexHarness().launch_and_wait(
occ-001608	tests/test_agent/test_harness.py:195 · 快照	test_ensure_agent_user_provisions_user_and_git_safe_dir	async_def	run_case	python_ast	async def run_case():
occ-001609	tests/test_agent/test_harness.py:197 · 快照	test_ensure_agent_user_provisions_user_and_git_safe_dir.run_case	await	await	python_ast	await sandbox_mod.ensure_agent_user(sb, “/workspace/repo”)
occ-001611	tests/test_agent/test_harness.py:212 · 快照	test_base_harness_run_calls_steps_in_order	async_def	run_case	python_ast	async def run_case():
occ-001612	tests/test_agent/test_harness.py:213 · 快照	test_base_harness_run_calls_steps_in_order.run_case	async_def	agent	python_ast	async def agent(_env):
occ-001613	tests/test_agent/test_harness.py:218 · 快照	test_base_harness_run_calls_steps_in_order.run_case	await	await	python_ast	rc = await ClaudeCodeHarness().run(
occ-001617	tests/test_agent/test_sandbox_exec_and_wait.py:59 · 快照	ShellFakeSandbox	async_def	aenter	python_ast	async def aenter(self):
occ-001618	tests/test_agent/test_sandbox_exec_and_wait.py:62 · 快照	ShellFakeSandbox	async_def	aexit	python_ast	async def aexit(self, *exc):
occ-001619	tests/test_agent/test_sandbox_exec_and_wait.py:65 · 快照	ShellFakeSandbox	async_def	write_file	python_ast	async def write_file(self, path, content, *, user=“root”):
occ-001620	tests/test_agent/test_sandbox_exec_and_wait.py:68 · 快照	ShellFakeSandbox	async_def	read_file	python_ast	async def read_file(self, path, *, user=“root”):
occ-001622	tests/test_agent/test_sandbox_exec_and_wait.py:71 · 快照	ShellFakeSandbox	async_def	exec	python_ast	async def exec(self, cmd, *, user=“root”, env=None, timeout=120, check=False, idempotent=True):
occ-001624	tests/test_agent/test_sandbox_exec_and_wait.py:121 · 快照	fast_marker_polls	async_def	_instant	python_ast	async def _instant(_seconds):
occ-001625	tests/test_agent/test_sandbox_exec_and_wait.py:134 · 快照	test_same_tag_reinvocation_actually_reruns	async_def	_two_attempts	python_ast	async def _two_attempts():
occ-001626	tests/test_agent/test_sandbox_exec_and_wait.py:135 · 快照	test_same_tag_reinvocation_actually_reruns._two_attempts	await	await	python_ast	first = await exec_and_wait(sb, cmd=“npm install”, time_budget_sec=60, tag=“npm”, want_output=True)
occ-001627	tests/test_agent/test_sandbox_exec_and_wait.py:136 · 快照	test_same_tag_reinvocation_actually_reruns._two_attempts	await	await	python_ast	second = await exec_and_wait(sb, cmd=“npm install”, time_budget_sec=60, tag=“npm”, want_output=True)
occ-001660	tests/test_distributed_rollout.py:612 · 快照	test_slow_task_acquire_does_not_block_async_generation	async_def	exercise	python_ast	async def exercise():
occ-001663	tests/test_distributed_rollout.py:618 · 快照	test_slow_task_acquire_does_not_block_async_generation.exercise	await	await	python_ast	await asyncio.sleep(0.01)
occ-001668	tests/test_distributed_rollout.py:623 · 快照	test_slow_task_acquire_does_not_block_async_generation.exercise	await	await	python_ast	assert len(await task) == 1
occ-001677	tests/test_distributed_rollout.py:683 · 快照	scheduler_factory.create.make_generator	async_def	execute	python_ast	async def execute(rollout_id, group=None):
occ-001679	tests/test_distributed_rollout.py:688 · 快照	scheduler_factory.create.make_generator.execute	await	await	python_ast	await asyncio.sleep(0.01)
occ-001681	tests/test_distributed_rollout.py:702 · 快照	scheduler_factory.create	async_def	initial_groups	python_ast	async def initial_groups(count):
occ-001684	tests/test_distributed_rollout.py:731 · 快照	scheduler_factory	async_def	cleanup	python_ast	async def cleanup():
occ-001686	tests/test_distributed_rollout.py:735 · 快照	scheduler_factory.cleanup	await	await	python_ast	await asyncio.gather(*producers, return_exceptions=True)
occ-001716	tests/test_distributed_rollout.py:940 · 快照	test_distributed_completed_groups_keep_rewards_and_masks	async_def	get_samples	python_ast	async def get_samples(count):
occ-001717	tests/test_distributed_rollout.py:944 · 快照	test_distributed_completed_groups_keep_rewards_and_masks	async_def	unexpected_generation	python_ast	async def unexpected_generation(*args):
occ-001718	tests/test_distributed_rollout.py:947 · 快照	test_distributed_completed_groups_keep_rewards_and_masks	async_def	republish_buffered	python_ast	async def republish_buffered(args, *kwargs):
occ-001721	tests/test_distributed_rollout.py:982 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results	async_def	generate_group	python_ast	async def generate_group(rollout_id, group=None):
occ-001722	tests/test_distributed_rollout.py:990 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.generate_group	await	await	python_ast	await release.wait()
occ-001724	tests/test_distributed_rollout.py:992 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.generate_group	await	await	python_ast	await asyncio.sleep(0)
occ-001726	tests/test_distributed_rollout.py:1000 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results	async_def	initial_groups	python_ast	async def initial_groups(count):
occ-001727	tests/test_distributed_rollout.py:1006 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results	async_def	exercise	python_ast	async def exercise():
occ-001728	tests/test_distributed_rollout.py:1007 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	await worker._start(0)
occ-001729	tests/test_distributed_rollout.py:1009 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	first = await asyncio.wait_for(worker._next(), timeout=5)
occ-001731	tests/test_distributed_rollout.py:1010 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	second = await asyncio.wait_for(worker._next(), timeout=5)
occ-001734	tests/test_distributed_rollout.py:1017 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	output = await asyncio.wait_for(worker._next(), timeout=5)
occ-001736	tests/test_distributed_rollout.py:1020 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	await asyncio.sleep(0.02)
occ-001738	tests/test_distributed_rollout.py:1022 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	await asyncio.sleep(0.02)
occ-001740	tests/test_distributed_rollout.py:1026 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	await worker._pause()
occ-001742	tests/test_distributed_rollout.py:1029 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	while (output := await asyncio.wait_for(worker._next(), timeout=5)) is not None:
occ-001746	tests/test_distributed_rollout.py:1037 · 快照	test_worker_refills_locally_and_slow_group_does_not_block_results.exercise	await	await	python_ast	await asyncio.gather(worker.producer, return_exceptions=True)
occ-001749	tests/test_distributed_rollout.py:1052 · 快照	<module>	async_def	_generate_locally	python_ast	async def _generate_locally(args, sample, sampling_params):
occ-001750	tests/test_distributed_rollout.py:1054 · 快照	_generate_locally	await	await	python_ast	await asyncio.sleep(0.01)
occ-001752	tests/test_distributed_rollout.py:1055 · 快照	_generate_locally	await	await	python_ast	await asyncio.sleep(0.01 * (sample.group_index % 3))
occ-001754	tests/test_distributed_rollout.py:1087 · 快照	<module>	async_def	_score_fanout	python_ast	async def _score_fanout(args, samples):
occ-001755	tests/test_distributed_rollout.py:1094 · 快照	<module>	async_def	_score_group	python_ast	async def _score_group(args, samples):
occ-001773	tests/test_distributed_rollout.py:1830 · 快照	test_cancelled_rebuffer_waiter_does_not_drop_its_continuation	async_def	exercise	python_ast	async def exercise():
occ-001775	tests/test_distributed_rollout.py:1832 · 快照	test_cancelled_rebuffer_waiter_does_not_drop_its_continuation.exercise	await	await	python_ast	await asyncio.sleep(0.001)
occ-001778	tests/test_distributed_rollout.py:1834 · 快照	test_cancelled_rebuffer_waiter_does_not_drop_its_continuation.exercise	await	await	python_ast	await asyncio.gather(*waiters, return_exceptions=True)
occ-001799	tests/test_distributed_rollout.py:2071 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation	async_def	run	python_ast	async def run():
occ-001802	tests/test_distributed_rollout.py:2078 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run	async_def	fetch	python_ast	async def fetch(count):
occ-001804	tests/test_distributed_rollout.py:2080 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run.fetch	await	await	python_ast	await release.wait()
occ-001806	tests/test_distributed_rollout.py:2083 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run	async_def	rebuffer	python_ast	async def rebuffer(value):
occ-001807	tests/test_distributed_rollout.py:2086 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run	async_def	unexpected	python_ast	async def unexpected(*args):
occ-001809	tests/test_distributed_rollout.py:2095 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run	await	await	python_ast	await entered.wait()
occ-001811	tests/test_distributed_rollout.py:2096 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run	await	await	python_ast	await worker._pause()
occ-001813	tests/test_distributed_rollout.py:2098 · 快照	test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run	await	await	python_ast	assert await task is None
occ-001826	tests/test_fully_async_rollout.py:63 · 快照	test_custom_data_source_keeps_original_entrypoint	async_def	generate	python_ast	async def generate(received_args, rollout_id, received_source):
occ-001837	tests/test_fully_async_rollout.py:234 · 快照	test_loop_backpressure_stops_topping_up_when_queue_is_full	async_def	_instant_generate	python_ast	async def _instant_generate(args, group, sampling_params, evaluation):
occ-001841	tests/test_fully_async_rollout.py:266 · 快照	test_local_worker_lifecycle_is_scoped_to_source	async_def	generate	python_ast	async def generate(args, group, sampling_params, evaluation):
occ-001842	tests/test_fully_async_rollout.py:267 · 快照	test_local_worker_lifecycle_is_scoped_to_source.generate	await	await	python_ast	await asyncio.sleep(0.01)
occ-001860	tests/test_optional_straw.py:85 · 快照	_run_default_without_straw	async_def	generate	python_ast	async def generate(*values):
occ-001936	tests/test_rollout_sample_hooks.py:16 · 快照	<module>	async_def	async_hook	python_ast	async def async_hook(args, sample, *, evaluation=False):
occ-001940	tests/test_rollout_sample_hooks.py:61 · 快照	test_concurrent_groups_keep_their_own_rollout_hook_context	async_def	generate	python_ast	async def generate(rollout_id):
occ-001941	tests/test_rollout_sample_hooks.py:63 · 快照	test_concurrent_groups_keep_their_own_rollout_hook_context.generate	await	await	python_ast	await asyncio.sleep(0)
occ-001943	tests/test_rollout_sample_hooks.py:64 · 快照	test_concurrent_groups_keep_their_own_rollout_hook_context.generate	await	await	python_ast	sample = await apply_rollout_sample_hooks(args, Sample(index=rollout_id))
occ-001944	tests/test_rollout_sample_hooks.py:67 · 快照	test_concurrent_groups_keep_their_own_rollout_hook_context	async_def	exercise	python_ast	async def exercise():
occ-001945	tests/test_rollout_sample_hooks.py:68 · 快照	test_concurrent_groups_keep_their_own_rollout_hook_context.exercise	await	await	python_ast	assert await asyncio.gather(generate(10), generate(11)) == [(“seen”, 10), (“seen”, 11)]
occ-001954	tests/test_rollout_straw_transport.py:375 · 快照	test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook	async_def	exercise	python_ast	async def exercise():
occ-001957	tests/test_rollout_straw_transport.py:379 · 快照	test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise	async_def	generate	python_ast	async def generate(index):
occ-001958	tests/test_rollout_straw_transport.py:381 · 快照	test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise.generate	await	await	python_ast	await second.wait()
occ-001962	tests/test_rollout_straw_transport.py:395 · 快照	test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise	async_def	abort	python_ast	async def abort(*a):
occ-001963	tests/test_rollout_straw_transport.py:409 · 快照	test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise	await	await	python_ast	return await asyncio.wait_for(sr.generate_rollout_async(args, 0, lambda count: [None] * count), timeout=20)
occ-001987	tests/test_score_centering_binary.py:111 · 快照	test_http_worker_decodes_off_event_loop.Response	async_def	aread	python_ast	async def aread(self):
occ-001988	tests/test_score_centering_binary.py:114 · 快照	test_http_worker_decodes_off_event_loop.Response	async_def	aclose	python_ast	async def aclose(self):
occ-001989	tests/test_score_centering_binary.py:118 · 快照	test_http_worker_decodes_off_event_loop.Client	async_def	post	python_ast	async def post(self, args, *kwargs):
occ-001992	tests/test_score_centering_transport.py:85 · 快照	test_generate_requests_sampler_topk	async_def	post	python_ast	async def post(url, payload, **kwargs):
occ-001994	tests/test_score_centering_transport.py:127 · 快照	test_r3_resume_appends_routes_without_replacing_the_persisted_prefix	async_def	post	python_ast	async def post(url, payload, **kwargs):
occ-001999	tests/test_score_centering_transport.py:204 · 快照	test_evaluation_preserves_training_score_centering	async_def	generate	python_ast	async def generate(received, sample, params):
occ-002000	tests/test_score_centering_transport.py:208 · 快照	test_evaluation_preserves_training_score_centering	async_def	hooks	python_ast	async def hooks(received, sample, **kwargs):
occ-002001	tests/test_score_centering_transport.py:215 · 快照	test_evaluation_preserves_training_score_centering	async_def	run	python_ast	async def run():
occ-002002	tests/test_score_centering_transport.py:216 · 快照	test_evaluation_preserves_training_score_centering.run	await	await	python_ast	await rollout.generate_and_rm(a, Sample(), {“temperature”: 0}, evaluation=True)
occ-002003	tests/test_score_centering_transport.py:217 · 快照	test_evaluation_preserves_training_score_centering.run	await	await	python_ast	await rollout.generate_and_rm(a, Sample(), {“temperature”: 0.8})
occ-002005	tests/test_score_centering_transport.py:552 · 快照	test_generate_requests_complete_top_p_probabilities	async_def	post	python_ast	async def post(url, payload, **kwargs):
occ-002008	tests/test_server_control.py:19 · 快照	test_rollout_boundary_prunes_failed_router_workers	async_def	respond	python_ast	async def respond(request):
occ-002012	tests/test_server_control.py:108 · 快照	test_abort_uses_supported_load_sections_and_waits_for_pd_transfers	async_def	post	python_ast	async def post(url, payload, **kwargs):
occ-002013	tests/test_server_control.py:114 · 快照	test_abort_uses_supported_load_sections_and_waits_for_pd_transfers	async_def	get	python_ast	async def get(url, **kwargs):
occ-002015	tests/test_server_control.py:168 · 快照	test_abort_retries_load_failure_until_idle	async_def	abort_once	python_ast	async def abort_once(url, request_timeout):
occ-002016	tests/test_server_control.py:171 · 快照	test_abort_retries_load_failure_until_idle	async_def	get_load	python_ast	async def get_load(url, request_timeout):
occ-002018	tests/test_server_control.py:187 · 快照	test_abort_servers_surfaces_partial_failure	async_def	abort	python_ast	async def abort(url, **kwargs):
occ-002020	tests/test_server_control.py:205 · 快照	test_http_post_forwards_timeout_and_closes_response.Response	async_def	aread	python_ast	async def aread(self):
occ-002021	tests/test_server_control.py:208 · 快照	test_http_post_forwards_timeout_and_closes_response.Response	async_def	aclose	python_ast	async def aclose(self):
occ-002022	tests/test_server_control.py:214 · 快照	test_http_post_forwards_timeout_and_closes_response.Client	async_def	post	python_ast	async def post(self, url, **kwargs):
occ-002024	tests/test_server_control.py:226 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget	async_def	check	python_ast	async def check():
occ-002025	tests/test_server_control.py:230 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	async_def	serve	python_ast	async def serve(reader, writer):
occ-002027	tests/test_server_control.py:239 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve	await	await	python_ast	headers = await reader.readuntil(b"\r\n\r\n")
occ-002029	tests/test_server_control.py:248 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve	await	await	python_ast	body = await reader.readexactly(length)
occ-002031	tests/test_server_control.py:250 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve	await	await	python_ast	await asyncio.sleep(0.1)
occ-002034	tests/test_server_control.py:252 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve	await	await	python_ast	await writer.drain()
occ-002038	tests/test_server_control.py:258 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve	await	await	python_ast	await writer.wait_closed()
occ-002040	tests/test_server_control.py:261 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	await	await	python_ast	server = await asyncio.start_server(serve, “127.0.0.1”, 0, backlog=2 * concurrency)
occ-002042	tests/test_server_control.py:264 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	async_with	async with	python_ast	async with httpx.AsyncClient(transport=http_utils._ShardedHTTPTransport(concurrency)) as client:
occ-002043	tests/test_server_control.py:266 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	async_def	request	python_ast	async def request(i):
occ-002044	tests/test_server_control.py:268 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check.request	async_with	async with	python_ast	async with client.stream(“POST”, url, content=body) as response:
occ-002045	tests/test_server_control.py:269 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check.request	await	await	python_ast	assert await response.aread() == body
occ-002046	tests/test_server_control.py:272 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	await	await	python_ast	await asyncio.gather(*(request(i) for i in range(concurrency + 3)))
occ-002048	tests/test_server_control.py:276 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	await	await	python_ast	await client.post(url + “/slow”, content=b"x", timeout=0.01)
occ-002049	tests/test_server_control.py:277 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	await	await	python_ast	assert (await client.post(url, content=b"after-timeout")).content == b"after-timeout"
occ-002051	tests/test_server_control.py:280 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	await	await	python_ast	await server.wait_closed()
occ-002053	tests/test_server_control.py:281 · 快照	test_http_transport_preserves_streams_timeouts_and_connection_budget.check	await	await	python_ast	await asyncio.gather(*tasks, return_exceptions=True)
occ-002062	tests/test_straw_fully_async_recovery.py:45 · 快照	<module>	async_def	_generate_with_interrupt	python_ast	async def _generate_with_interrupt(args, sample, sampling_params):
occ-002063	tests/test_straw_fully_async_recovery.py:49 · 快照	_generate_with_interrupt	await	await	python_ast	await asyncio.Event().wait()
occ-002066	tests/test_straw_fully_async_recovery.py:52 · 快照	_generate_with_interrupt	await	await	python_ast	await asyncio.Event().wait()
occ-002069	tests/test_straw_fully_async_recovery.py:53 · 快照	_generate_with_interrupt	await	await	python_ast	sample = await _generate_locally(args, sample, sampling_params)
occ-002071	tests/test_straw_fully_async_recovery.py:86 · 快照	<module>	async_def	_reward_once	python_ast	async def _reward_once(args, sample):
occ-002099	tests/test_straw_r3.py:159 · 快照	test_cancelled_straw_publication_drains_before_releasing_capacity	async_def	run	python_ast	async def run():
occ-002101	tests/test_straw_r3.py:163 · 快照	test_cancelled_straw_publication_drains_before_releasing_capacity.run	await	await	python_ast	assert await asyncio.to_thread(entered.wait, 5)
occ-002105	tests/test_straw_r3.py:167 · 快照	test_cancelled_straw_publication_drains_before_releasing_capacity.run	await	await	python_ast	await asyncio.sleep(0.05)
occ-002108	tests/test_straw_r3.py:169 · 快照	test_cancelled_straw_publication_drains_before_releasing_capacity.run	await	await	python_ast	await asyncio.sleep(0.05)
occ-002112	tests/test_straw_r3.py:174 · 快照	test_cancelled_straw_publication_drains_before_releasing_capacity.run	await	await	python_ast	results = await asyncio.gather(*tasks, return_exceptions=True)
occ-002122	tests/test_streaming_rollout.py:170 · 快照	_http_stream	async_generator_def	chunk_lines	python_ast	async def chunk_lines():
occ-002123	tests/test_streaming_rollout.py:172 · 快照	_http_stream.chunk_lines	async_yield	yield in async generator	python_ast	yield “data: " + json.dumps(chunk)
occ-002125	tests/test_streaming_rollout.py:177 · 快照	_http_stream	async_generator_def	stream	python_ast	async def stream(method, url, json, headers):
occ-002126	tests/test_streaming_rollout.py:182 · 快照	_http_stream.stream	async_yield	yield in async generator	python_ast	yield response
occ-002131	tests/test_streaming_rollout.py:332 · 快照	test_server_abort_keeps_last_observed_prefix	async_generator_def	lines	python_ast	async def lines():
occ-002132	tests/test_streaming_rollout.py:334 · 快照	test_server_abort_keeps_last_observed_prefix.lines	async_yield	yield in async generator	python_ast	yield “data: " + json.dumps(_chunk(“a”, [[-0.1, 11, None]], 1))
occ-002138	tests/test_streaming_rollout.py:358 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix	async_generator_def	lines	python_ast	async def lines():
occ-002139	tests/test_streaming_rollout.py:359 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix.lines	async_yield	yield in async generator	python_ast	yield “data: " + json.dumps(
occ-002141	tests/test_streaming_rollout.py:369 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix.lines	await	await	python_ast	await asyncio.Event().wait()
occ-002144	tests/test_streaming_rollout.py:375 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix	async_def	server_generate	python_ast	async def server_generate(args, sample, sampling_params):
occ-002146	tests/test_streaming_rollout.py:377 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix.server_generate	await	await	python_ast	await server_released.wait()
occ-002148	tests/test_streaming_rollout.py:381 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix	async_def	get_workers	python_ast	async def get_workers(_url, *, timeout):
occ-002149	tests/test_streaming_rollout.py:384 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix	async_def	abort_servers	python_ast	async def abort_servers(urls):
occ-002151	tests/test_streaming_rollout.py:392 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix	async_def	exercise	python_ast	async def exercise():
occ-002154	tests/test_streaming_rollout.py:401 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix.exercise	await	await	python_ast	await asyncio.gather(first_chunk_seen.wait(), server_started.wait())
occ-002158	tests/test_streaming_rollout.py:402 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix.exercise	await	await	python_ast	await sglang_rollout.abort(args, rollout_id=0)
occ-002159	tests/test_streaming_rollout.py:403 · 快照	test_stream_cancellation_closes_request_and_keeps_prefix.exercise	await	await	python_ast	return await asyncio.gather(request_task, server_task)
occ-002164	tests/test_streaming_rollout.py:419 · 快照	test_unrelated_stream_cancellation_propagates	async_generator_def	lines	python_ast	async def lines():
occ-002166	tests/test_streaming_rollout.py:421 · 快照	test_unrelated_stream_cancellation_propagates.lines	await	await	python_ast	await asyncio.Event().wait()
occ-002169	tests/test_streaming_rollout.py:422 · 快照	test_unrelated_stream_cancellation_propagates.lines	async_yield	yield in async generator	python_ast	yield “unreachable”
occ-002170	tests/test_streaming_rollout.py:427 · 快照	test_unrelated_stream_cancellation_propagates	async_def	exercise	python_ast	async def exercise():
occ-002172	tests/test_streaming_rollout.py:435 · 快照	test_unrelated_stream_cancellation_propagates.exercise	await	await	python_ast	await request_started.wait()
occ-002176	tests/test_streaming_rollout.py:439 · 快照	test_unrelated_stream_cancellation_propagates.exercise	await	await	python_ast	await task
occ-002178	tests/test_streaming_rollout.py:466 · 快照	test_partial_abort_buffers_and_resumes_only_aborted_siblings	async_def	exercise	python_ast	async def exercise():
occ-002181	tests/test_streaming_rollout.py:486 · 快照	test_partial_abort_buffers_and_resumes_only_aborted_siblings.exercise	await	await	python_ast	buffered_groups = await sglang_rollout.abort(args, rollout_id=7)
occ-002182	tests/test_streaming_rollout.py:489 · 快照	test_partial_abort_buffers_and_resumes_only_aborted_siblings.exercise	async_def	resume_generate	python_ast	async def resume_generate(args, sample, sampling_params):
occ-002183	tests/test_streaming_rollout.py:500 · 快照	test_partial_abort_buffers_and_resumes_only_aborted_siblings.exercise	async_def	reward	python_ast	async def reward(_args, sample):
occ-002185	tests/test_streaming_rollout.py:511 · 快照	test_partial_abort_buffers_and_resumes_only_aborted_siblings.exercise	await	await	python_ast	resumed_group = await sglang_rollout.generate_and_rm_group(args, mixed_group, {“max_new_tokens”: 1})
occ-002187	tests/test_streaming_rollout.py:533 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse	async_def	exercise	python_ast	async def exercise():
occ-002193	tests/test_streaming_rollout.py:550 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise	async_def	generate	python_ast	async def generate(_args, sample, params, evaluation=False):
occ-002196	tests/test_streaming_rollout.py:558 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise.generate	await	await	python_ast	await finish.wait()
occ-002199	tests/test_streaming_rollout.py:573 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise	await	await	python_ast	await asyncio.wait_for(first_batch.wait(), 1)
occ-002205	tests/test_streaming_rollout.py:579 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise	await	await	python_ast	await tasks[70]
occ-002206	tests/test_streaming_rollout.py:581 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise	await	await	python_ast	await asyncio.wait_for(all_started.wait(), 1)
occ-002210	tests/test_streaming_rollout.py:585 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise	await	await	python_ast	await asyncio.gather(*(task for i, task in enumerate(tasks) if i != 70))
occ-002212	tests/test_streaming_rollout.py:586 · 快照	test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise	await	await	python_ast	assert (await start(128)).status == Sample.Status.COMPLETED
occ-002214	tests/test_streaming_rollout.py:593 · 快照	test_abort_while_waiting_for_generation_pacer_does_not_start_request	async_def	exercise	python_ast	async def exercise():
occ-002217	tests/test_streaming_rollout.py:600 · 快照	test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise	async_def	wait_for_release	python_ast	async def wait_for_release():
occ-002219	tests/test_streaming_rollout.py:602 · 快照	test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise.wait_for_release	await	await	python_ast	await release.wait()
occ-002221	tests/test_streaming_rollout.py:603 · 快照	test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise.wait_for_release	await	await	python_ast	await wait()
occ-002222	tests/test_streaming_rollout.py:605 · 快照	test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise	async_def	unexpected_generate	python_ast	async def unexpected_generate(args, *kwargs):
occ-002224	tests/test_streaming_rollout.py:612 · 快照	test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise	await	await	python_ast	await queued.wait()
occ-002227	tests/test_streaming_rollout.py:615 · 快照	test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise	await	await	python_ast	assert (await task).status == Sample.Status.ABORTED
occ-002243	tests/training_recovery_test_helpers.py:15 · 快照	<module>	async_def	reward	python_ast	async def reward(args, sample, **kwargs):

返回分类索引 · 返回学习首页