asyncio 模块的导入、直接调用与非调用引用。
固定源码版本：2f2318653f6f794dddd321eff7c9d4b7b174643f。本表共 313 条静态出现记录；不是运行次数。
同一个直接 API 表达式只记为 api_call 或 api_reference 中的一类。实例候选不计入直接原生 API 总数。
| ID | 位置 / 快照 | 所属符号 | 种类 | API / 语法 | 来源判定 | 源码行 |
|---|---|---|---|---|---|---|
| occ-000001 | examples/coding_agent_rl/generate.py:20 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000004 | examples/coding_agent_rl/generate.py:92 · 快照 | <module> | api_call | asyncio.Semaphore | lexical_import_resolution | _BOOT_SEM = asyncio.Semaphore(CONFIG.boot_concurrency) |
| occ-000015 | examples/coding_agent_rl/generate.py:127 · 快照 | boot_agent_sandbox | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(1 + attempt + random.random()) |
| occ-000021 | examples/coding_agent_rl/generate.py:202 · 快照 | generate | api_call | asyncio.timeout | lexical_import_resolution | async with asyncio.timeout(CONFIG.rollout_guard_sec): |
| occ-000028 | examples/coding_agent_rl/generate.py:270 · 快照 | generate | api_reference | asyncio.TimeoutError | lexical_import_resolution | except asyncio.TimeoutError: |
| occ-000031 | examples/coding_agent_rl/generate.py:283 · 快照 | generate | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(10) |
| occ-000032 | examples/coding_agent_rl/generate.py:290 · 快照 | _log_timeout_diagnostic | api_call | asyncio.all_tasks | lexical_import_resolution | pending = [t for t in asyncio.all_tasks() if not t.done()] |
| occ-000034 | examples/coding_agent_rl/swe.py:27 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000150 | examples/coding_agent_rl/swe.py:466 · 快照 | _grade_swebench | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather( |
| occ-000166 | examples/multi_agent/agent_system.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000185 | examples/multi_agent/agent_system.py:222 · 快照 | run_agent_system | api_call | asyncio.gather | lexical_import_resolution | results = await asyncio.gather(*tasks, return_exceptions=True) |
| occ-000188 | examples/multi_agent/agent_system.py:244 · 快照 | run_agent_system | api_call | asyncio.gather | lexical_import_resolution | rewrited_solutions_raw = await asyncio.gather(*tasks, return_exceptions=True) |
| occ-000204 | examples/retool/tool_sandbox.py:10 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000206 | examples/retool/tool_sandbox.py:38 · 快照 | <module> | api_call | asyncio.Semaphore | lexical_import_resolution | SEMAPHORE = asyncio.Semaphore(TOOL_CONFIGS[“tool_concurrency”]) |
| occ-000222 | examples/search-r1/generate_with_search.py:4 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000223 | examples/search-r1/generate_with_search.py:41 · 快照 | <module> | api_call | asyncio.Semaphore | lexical_import_resolution | SEMAPHORE = asyncio.Semaphore(SEARCH_R1_CONFIGS[“search_concurrency”]) |
| occ-000236 | examples/search-r1/google_search_server.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000239 | examples/search-r1/google_search_server.py:42 · 快照 | <module> | api_reference | asyncio.Semaphore | lexical_import_resolution | async def fetch(session: aiohttp.ClientSession, url: str, semaphore: asyncio.Semaphore) -> str: |
| occ-000245 | examples/search-r1/google_search_server.py:59 · 快照 | fetch | api_reference | asyncio.TimeoutError | lexical_import_resolution | except (aiohttp.ClientError, asyncio.TimeoutError): |
| occ-000247 | examples/search-r1/google_search_server.py:64 · 快照 | fetch_all | api_call | asyncio.Semaphore | lexical_import_resolution | semaphore = asyncio.Semaphore(limit) |
| occ-000250 | examples/search-r1/google_search_server.py:70 · 快照 | fetch_all | api_call | asyncio.gather | lexical_import_resolution | return await asyncio.gather(*tasks) |
| occ-000355 | slime/agent/adapters/common.py:15 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000362 | slime/agent/adapters/common.py:157 · 快照 | BaseAdapter.init | api_reference | asyncio.Task | lexical_import_resolution | self.inflight: dict[str, set[asyncio.Task]] = {} |
| occ-000368 | slime/agent/adapters/common.py:233 · 快照 | BaseAdapter.shutdown_session._drain | api_call | asyncio.wait | lexical_import_resolution | _, pending = await asyncio.wait(tasks, timeout=wait_timeout) |
| occ-000371 | slime/agent/adapters/common.py:237 · 快照 | BaseAdapter.shutdown_session._drain | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*pending, return_exceptions=True) |
| occ-000374 | slime/agent/adapters/common.py:241 · 快照 | BaseAdapter.shutdown_session | api_call | asyncio.wrap_future | lexical_import_resolution | await asyncio.wrap_future(asyncio.run_coroutine_threadsafe(_drain(), loop)) |
| occ-000375 | slime/agent/adapters/common.py:241 · 快照 | BaseAdapter.shutdown_session | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | await asyncio.wrap_future(asyncio.run_coroutine_threadsafe(_drain(), loop)) |
| occ-000385 | slime/agent/adapters/common.py:337 · 快照 | BaseAdapter._run_turn | api_call | asyncio.current_task | lexical_import_resolution | task = asyncio.current_task() |
| occ-000390 | slime/agent/adapters/common.py:364 · 快照 | BaseAdapter._run_turn | api_reference | asyncio.CancelledError | lexical_import_resolution | except (ConnectionResetError, asyncio.CancelledError) as e: |
| occ-000391 | slime/agent/adapters/common.py:372 · 快照 | BaseAdapter._run_turn | api_reference | asyncio.CancelledError | lexical_import_resolution | if isinstance(e, asyncio.CancelledError): |
| occ-000409 | slime/agent/adapters/common.py:502 · 快照 | call_sglang_generate | api_reference | asyncio.CancelledError | lexical_import_resolution | except (asyncio.CancelledError, aiohttp.ClientError, asyncio.TimeoutError) as e: |
| occ-000410 | slime/agent/adapters/common.py:502 · 快照 | call_sglang_generate | api_reference | asyncio.TimeoutError | lexical_import_resolution | except (asyncio.CancelledError, aiohttp.ClientError, asyncio.TimeoutError) as e: |
| occ-000423 | slime/agent/adapters/common.py:547 · 快照 | _abort_sglang_request | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*(abort_worker(url) for url in worker_urls)) |
| occ-000467 | slime/agent/aiohttp_threaded.py:5 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000470 | slime/agent/aiohttp_threaded.py:30 · 快照 | AppHandle | api_reference | asyncio.AbstractEventLoop | lexical_import_resolution | loop: asyncio.AbstractEventLoop |
| occ-000473 | slime/agent/aiohttp_threaded.py:38 · 快照 | AppHandle.stop | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | fut = asyncio.run_coroutine_threadsafe(_shutdown(), self.loop) |
| occ-000478 | slime/agent/aiohttp_threaded.py:66 · 快照 | run_app_in_thread._run | api_call | asyncio.new_event_loop | lexical_import_resolution | loop = asyncio.new_event_loop() |
| occ-000479 | slime/agent/aiohttp_threaded.py:67 · 快照 | run_app_in_thread._run | api_call | asyncio.set_event_loop | lexical_import_resolution | asyncio.set_event_loop(loop) |
| occ-000501 | slime/agent/harness/common.py:18 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000517 | slime/agent/harness/common.py:148 · 快照 | install_npm_cli | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(NPM_INSTALL_BACKOFF_SEC * (attempt + 1)) |
| occ-000521 | slime/agent/sandbox.py:11 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000529 | slime/agent/sandbox.py:75 · 快照 | _await_done_marker | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(5) |
| occ-000542 | slime/agent/sandbox.py:269 · 快照 | E2BSandbox._rpc_retry | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(backoff) |
| occ-000568 | slime/backends/megatron_utils/server/megatron_server.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000592 | slime/backends/megatron_utils/server/megatron_server.py:356 · 快照 | _ray_get | api_call | asyncio.to_thread | lexical_import_resolution | return await asyncio.to_thread(ray.get, ref) |
| occ-000600 | slime/backends/megatron_utils/server/megatron_server.py:399 · 快照 | _wait_until_idle | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.1) |
| occ-000604 | slime/backends/megatron_utils/server/megatron_server.py:429 · 快照 | _build_http_app | api_call | asyncio.Lock | lexical_import_resolution | update_lock = asyncio.Lock() |
| occ-000613 | slime/backends/megatron_utils/server/megatron_server.py:464 · 快照 | _build_http_app.update_from_disk | api_call | asyncio.get_running_loop | lexical_import_resolution | update_future = asyncio.get_running_loop().create_future() |
| occ-000616 | slime/backends/megatron_utils/server/megatron_server.py:471 · 快照 | _build_http_app.update_from_disk | api_call | asyncio.shield | lexical_import_resolution | result = await asyncio.shield(update_future) |
| occ-000622 | slime/backends/megatron_utils/server/megatron_server.py:483 · 快照 | _build_http_app.update_from_disk | api_call | asyncio.to_thread | lexical_import_resolution | update_result = await asyncio.to_thread(update_from_disk_fn, model_path) |
| occ-000635 | slime/backends/megatron_utils/server/megatron_server.py:584 · 快照 | _build_http_app.generate | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.05) |
| occ-000636 | slime/backends/megatron_utils/server/megatron_server.py:585 · 快照 | _build_http_app.generate | api_reference | asyncio.CancelledError | lexical_import_resolution | except asyncio.CancelledError: |
| occ-000668 | slime/backends/sglang_utils/server_control.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000679 | slime/backends/sglang_utils/server_control.py:57 · 快照 | get_live_router_workers | api_call | asyncio.gather | lexical_import_resolution | workers = await asyncio.gather(*(check(worker) for worker in response.json()[“workers”])) |
| occ-000696 | slime/backends/sglang_utils/server_control.py:153 · 快照 | _abort_server_once | api_call | asyncio.wait_for | lexical_import_resolution | await asyncio.wait_for( |
| occ-000699 | slime/backends/sglang_utils/server_control.py:160 · 快照 | _get_server_load | api_call | asyncio.wait_for | lexical_import_resolution | return await asyncio.wait_for( |
| occ-000701 | slime/backends/sglang_utils/server_control.py:176 · 快照 | abort_server_until_idle | api_call | asyncio.get_running_loop | lexical_import_resolution | loop = asyncio.get_running_loop() |
| occ-000705 | slime/backends/sglang_utils/server_control.py:233 · 快照 | abort_server_until_idle | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(min(retry_interval, remaining)) |
| occ-000708 | slime/backends/sglang_utils/server_control.py:245 · 快照 | abort_servers_until_idle | api_call | asyncio.gather | lexical_import_resolution | results = await asyncio.gather( |
| occ-000745 | slime/data/queue_data_source.py:11 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000810 | slime/data/queue_data_source.py:1115 · 快照 | QueueReader.get_samples_async | api_call | asyncio.get_running_loop | lexical_import_resolution | return await asyncio.get_running_loop().run_in_executor(self._reader, self.get_samples, num_samples) |
| occ-000822 | slime/data/transport.py:5 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000835 | slime/data/transport.py:372 · 快照 | run_rollout_io | api_call | asyncio.get_running_loop | lexical_import_resolution | loop = asyncio.get_running_loop() |
| occ-000837 | slime/data/transport.py:375 · 快照 | run_rollout_io | api_call | asyncio.Semaphore | lexical_import_resolution | _async_limits[key] = asyncio.Semaphore(getattr(args, “rollout_io_concurrency”, 4)) |
| occ-000839 | slime/data/transport.py:377 · 快照 | run_rollout_io | api_call | asyncio.create_task | lexical_import_resolution | pending = asyncio.create_task(asyncio.to_thread(function, *values, **kwargs)) |
| occ-000840 | slime/data/transport.py:377 · 快照 | run_rollout_io | api_call | asyncio.to_thread | lexical_import_resolution | pending = asyncio.create_task(asyncio.to_thread(function, *values, **kwargs)) |
| occ-000842 | slime/data/transport.py:379 · 快照 | run_rollout_io | api_call | asyncio.shield | lexical_import_resolution | return await asyncio.shield(pending) |
| occ-000843 | slime/data/transport.py:380 · 快照 | run_rollout_io | api_reference | asyncio.CancelledError | lexical_import_resolution | except asyncio.CancelledError: |
| occ-000846 | slime/data/transport.py:385 · 快照 | run_rollout_io | api_call | asyncio.shield | lexical_import_resolution | await asyncio.shield(pending) |
| occ-000847 | slime/data/transport.py:386 · 快照 | run_rollout_io | api_reference | asyncio.CancelledError | lexical_import_resolution | except asyncio.CancelledError: |
| occ-000851 | slime/data/transport.py:413 · 快照 | unpack_published_payload | api_call | asyncio.to_thread | lexical_import_resolution | return await asyncio.to_thread(unpack_rollout_payload, value) |
| occ-000853 | slime/data/transport.py:419 · 快照 | unpack_published_payload | api_call | asyncio.to_thread | lexical_import_resolution | return await asyncio.to_thread(unpack_rollout_payload, value) |
| occ-000910 | slime/rollout/fully_async_distributed.py:3 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-000936 | slime/rollout/fully_async_distributed.py:280 · 快照 | _GenerationActor.start | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | future = asyncio.run_coroutine_threadsafe(self._start(rollout_id), get_async_loop().loop) |
| occ-000938 | slime/rollout/fully_async_distributed.py:281 · 快照 | _GenerationActor.start | api_call | asyncio.wrap_future | lexical_import_resolution | await asyncio.wrap_future(future) |
| occ-000942 | slime/rollout/fully_async_distributed.py:291 · 快照 | _GenerationActor._start | api_call | asyncio.Queue | lexical_import_resolution | self.outputs = asyncio.Queue(maxsize=1) |
| occ-000943 | slime/rollout/fully_async_distributed.py:292 · 快照 | _GenerationActor._start | api_call | asyncio.create_task | lexical_import_resolution | self.producer = asyncio.create_task(self._produce()) |
| occ-000945 | slime/rollout/fully_async_distributed.py:295 · 快照 | _GenerationActor.pause | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | future = asyncio.run_coroutine_threadsafe(self._pause(), get_async_loop().loop) |
| occ-000947 | slime/rollout/fully_async_distributed.py:296 · 快照 | _GenerationActor.pause | api_call | asyncio.wrap_future | lexical_import_resolution | await asyncio.wrap_future(future) |
| occ-000950 | slime/rollout/fully_async_distributed.py:302 · 快照 | _GenerationActor.next | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | future = asyncio.run_coroutine_threadsafe(self._next(), get_async_loop().loop) |
| occ-000952 | slime/rollout/fully_async_distributed.py:303 · 快照 | _GenerationActor.next | api_call | asyncio.wrap_future | lexical_import_resolution | return await asyncio.wrap_future(future) |
| occ-000954 | slime/rollout/fully_async_distributed.py:306 · 快照 | _GenerationActor._next | api_call | asyncio.create_task | lexical_import_resolution | take = asyncio.create_task(self.outputs.get()) |
| occ-000957 | slime/rollout/fully_async_distributed.py:308 · 快照 | _GenerationActor._next | api_call | asyncio.wait | lexical_import_resolution | await asyncio.wait((take, self.producer), return_when=asyncio.FIRST_COMPLETED) |
| occ-000958 | slime/rollout/fully_async_distributed.py:308 · 快照 | _GenerationActor._next | api_reference | asyncio.FIRST_COMPLETED | lexical_import_resolution | await asyncio.wait((take, self.producer), return_when=asyncio.FIRST_COMPLETED) |
| occ-000966 | slime/rollout/fully_async_distributed.py:317 · 快照 | _GenerationActor._next | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(take, return_exceptions=True) |
| occ-000973 | slime/rollout/fully_async_distributed.py:334 · 快照 | _GenerationActor._produce.<comprehension> | api_call | asyncio.create_task | lexical_import_resolution | tasks.extend(asyncio.create_task(generate_slot(group)) for group in groups) |
| occ-000975 | slime/rollout/fully_async_distributed.py:337 · 快照 | _GenerationActor._produce | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.001) |
| occ-000977 | slime/rollout/fully_async_distributed.py:338 · 快照 | _GenerationActor._produce | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*tasks) |
| occ-000980 | slime/rollout/fully_async_distributed.py:342 · 快照 | _GenerationActor._produce | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*tasks, return_exceptions=True) |
| occ-000987 | slime/rollout/fully_async_distributed.py:373 · 快照 | _GenerationActor._generate_group | api_call | asyncio.to_thread | lexical_import_resolution | await asyncio.to_thread( |
| occ-000991 | slime/rollout/fully_async_distributed.py:394 · 快照 | _GenerationActor._generate_group | api_call | asyncio.to_thread | lexical_import_resolution | group = await asyncio.to_thread(self.data_source.materialize_samples, group) |
| occ-000993 | slime/rollout/fully_async_distributed.py:401 · 快照 | _GenerationActor._rebuffer | api_call | asyncio.get_running_loop | lexical_import_resolution | future = asyncio.get_running_loop().create_future() |
| occ-000995 | slime/rollout/fully_async_distributed.py:404 · 快照 | _GenerationActor._rebuffer | api_call | asyncio.create_task | lexical_import_resolution | self._rebuffer_task = asyncio.create_task(self._flush_rebuffers()) |
| occ-000997 | slime/rollout/fully_async_distributed.py:405 · 快照 | _GenerationActor._rebuffer | api_call | asyncio.shield | lexical_import_resolution | await asyncio.shield(future) |
| occ-001000 | slime/rollout/fully_async_distributed.py:409 · 快照 | _GenerationActor._flush_rebuffers | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.01) |
| occ-001002 | slime/rollout/fully_async_distributed.py:413 · 快照 | _GenerationActor._flush_rebuffers | api_call | asyncio.to_thread | lexical_import_resolution | await asyncio.to_thread(self.data_source.add_samples, [group for group, _ in batch]) |
| occ-001008 | slime/rollout/fully_async_distributed.py:435 · 快照 | _GenerationActor.close | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | future = asyncio.run_coroutine_threadsafe(self._close(), get_async_loop().loop) |
| occ-001010 | slime/rollout/fully_async_distributed.py:436 · 快照 | _GenerationActor.close | api_call | asyncio.wrap_future | lexical_import_resolution | await asyncio.wrap_future(future) |
| occ-001014 | slime/rollout/fully_async_distributed.py:442 · 快照 | _GenerationActor._close | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(self.producer, return_exceptions=True) |
| occ-001017 | slime/rollout/fully_async_distributed.py:447 · 快照 | _GenerationActor._close | api_call | asyncio.get_running_loop | lexical_import_resolution | await asyncio.get_running_loop().shutdown_default_executor() |
| occ-001022 | slime/rollout/fully_async_rollout.py:31 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001041 | slime/rollout/fully_async_rollout.py:165 · 快照 | AsyncRolloutWorker._thread_main | api_call | asyncio.run | lexical_import_resolution | asyncio.run(self._loop()) |
| occ-001044 | slime/rollout/fully_async_rollout.py:174 · 快照 | AsyncRolloutWorker._loop | api_reference | asyncio.Task | lexical_import_resolution | active_tasks: set[asyncio.Task] = set() |
| occ-001048 | slime/rollout/fully_async_rollout.py:192 · 快照 | AsyncRolloutWorker._loop | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0) |
| occ-001050 | slime/rollout/fully_async_rollout.py:209 · 快照 | AsyncRolloutWorker._loop | api_call | asyncio.create_task | lexical_import_resolution | task = asyncio.create_task( |
| occ-001054 | slime/rollout/fully_async_rollout.py:226 · 快照 | AsyncRolloutWorker._loop | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(self.poll_interval) |
| occ-001056 | slime/rollout/fully_async_rollout.py:237 · 快照 | AsyncRolloutWorker._loop | api_call | asyncio.wait | lexical_import_resolution | await asyncio.wait(active_tasks, timeout=30) |
| occ-001057 | slime/rollout/fully_async_rollout.py:242 · 快照 | AsyncRolloutWorker._make_done_cb | api_reference | asyncio.Task | lexical_import_resolution | def _cb(done_task: asyncio.Task) -> None: |
| occ-001059 | slime/rollout/fully_async_rollout.py:245 · 快照 | AsyncRolloutWorker._make_done_cb._cb | api_reference | asyncio.CancelledError | lexical_import_resolution | except asyncio.CancelledError: |
| occ-001065 | slime/rollout/fully_async_rollout.py:312 · 快照 | _generate_rollout_async | api_call | asyncio.to_thread | lexical_import_resolution | await asyncio.to_thread( |
| occ-001068 | slime/rollout/fully_async_rollout.py:324 · 快照 | _generate_rollout_async | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.05) |
| occ-001070 | slime/rollout/fully_async_rollout.py:357 · 快照 | _generate_rollout_async | api_call | asyncio.to_thread | lexical_import_resolution | output = await asyncio.to_thread( |
| occ-001076 | slime/rollout/rm_hub/init.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001081 | slime/rollout/rm_hub/init.py:52 · 快照 | remote_rm | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(backoff) |
| occ-001090 | slime/rollout/rm_hub/init.py:109 · 快照 | batched_async_rm | api_call | asyncio.gather | lexical_import_resolution | rewards = await asyncio.gather(*tasks) |
| occ-001115 | slime/rollout/sglang_rollout.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001117 | slime/rollout/sglang_rollout.py:95 · 快照 | GenerateState.init | api_call | asyncio.Semaphore | lexical_import_resolution | self.semaphore = asyncio.Semaphore( |
| occ-001119 | slime/rollout/sglang_rollout.py:145 · 快照 | GenerateState.submit_generate_tasks | api_call | asyncio.create_task | lexical_import_resolution | asyncio.create_task( |
| occ-001125 | slime/rollout/sglang_rollout.py:263 · 快照 | _run_request_abortable_generate | api_call | asyncio.current_task | lexical_import_resolution | task = asyncio.current_task() |
| occ-001127 | slime/rollout/sglang_rollout.py:268 · 快照 | _run_request_abortable_generate | api_reference | asyncio.CancelledError | lexical_import_resolution | except asyncio.CancelledError: |
| occ-001141 | slime/rollout/sglang_rollout.py:411 · 快照 | generate_and_rm_group | api_call | asyncio.create_task | lexical_import_resolution | asyncio.create_task(generate_and_rm(args, sample, current_sampling_params, evaluation=evaluation)) |
| occ-001143 | slime/rollout/sglang_rollout.py:414 · 快照 | generate_and_rm_group | api_call | asyncio.gather | lexical_import_resolution | group = await asyncio.gather(*tasks) |
| occ-001151 | slime/rollout/sglang_rollout.py:449 · 快照 | abort | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*cancellable_tasks, return_exceptions=True) |
| occ-001153 | slime/rollout/sglang_rollout.py:454 · 快照 | abort | api_call | asyncio.wait | lexical_import_resolution | done, state.pendings = await asyncio.wait(state.pendings, return_when=asyncio.FIRST_COMPLETED) |
| occ-001154 | slime/rollout/sglang_rollout.py:454 · 快照 | abort | api_reference | asyncio.FIRST_COMPLETED | lexical_import_resolution | done, state.pendings = await asyncio.wait(state.pendings, return_when=asyncio.FIRST_COMPLETED) |
| occ-001159 | slime/rollout/sglang_rollout.py:523 · 快照 | generate_rollout_async | api_call | asyncio.wait | lexical_import_resolution | done, state.pendings = await asyncio.wait(state.pendings, return_when=asyncio.FIRST_COMPLETED) |
| occ-001160 | slime/rollout/sglang_rollout.py:523 · 快照 | generate_rollout_async | api_reference | asyncio.FIRST_COMPLETED | lexical_import_resolution | done, state.pendings = await asyncio.wait(state.pendings, return_when=asyncio.FIRST_COMPLETED) |
| occ-001163 | slime/rollout/sglang_rollout.py:545 · 快照 | generate_rollout_async | api_call | asyncio.to_thread | lexical_import_resolution | await asyncio.to_thread( |
| occ-001171 | slime/rollout/sglang_rollout.py:594 · 快照 | generate_rollout_async | api_call | asyncio.to_thread | lexical_import_resolution | output = await asyncio.to_thread( |
| occ-001174 | slime/rollout/sglang_rollout.py:609 · 快照 | eval_rollout | api_call | asyncio.gather | lexical_import_resolution | results_list = await asyncio.gather(*coros) |
| occ-001176 | slime/rollout/sglang_rollout.py:712 · 快照 | eval_rollout_single_dataset | api_call | asyncio.create_task | lexical_import_resolution | asyncio.create_task( |
| occ-001177 | slime/rollout/sglang_rollout.py:725 · 快照 | eval_rollout_single_dataset | api_call | asyncio.as_completed | lexical_import_resolution | for coro in asyncio.as_completed(tasks): |
| occ-001196 | slime/utils/async_utils.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001199 | slime/utils/async_utils.py:25 · 快照 | AsyncPacer.wait | api_call | asyncio.get_running_loop | lexical_import_resolution | loop = asyncio.get_running_loop() |
| occ-001205 | slime/utils/async_utils.py:40 · 快照 | AsyncPacer._release | api_call | asyncio.get_running_loop | lexical_import_resolution | asyncio.get_running_loop().call_later(0.001, self._release) |
| occ-001207 | slime/utils/async_utils.py:48 · 快照 | AsyncLoopThread.init | api_call | asyncio.new_event_loop | lexical_import_resolution | self.loop = asyncio.new_event_loop() |
| occ-001210 | slime/utils/async_utils.py:53 · 快照 | AsyncLoopThread._start_loop | api_call | asyncio.set_event_loop | lexical_import_resolution | asyncio.set_event_loop(self.loop) |
| occ-001212 | slime/utils/async_utils.py:58 · 快照 | AsyncLoopThread.run | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | return asyncio.run_coroutine_threadsafe(coro, self.loop).result() |
| occ-001247 | slime/utils/http_utils.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001252 | slime/utils/http_utils.py:186 · 快照 | _ShardedHTTPTransport.aclose | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*(transport.aclose() for transport in self._transports)) |
| occ-001257 | slime/utils/http_utils.py:204 · 快照 | _post | api_call | asyncio.to_thread | lexical_import_resolution | output = await asyncio.to_thread(decode_score_centering_response, content, score_centering_top_k) |
| occ-001259 | slime/utils/http_utils.py:223 · 快照 | _post | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(1) |
| occ-001350 | slime_plugins/rollout_buffer/rollout_buffer_example.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001357 | slime_plugins/rollout_buffer/rollout_buffer_example.py:149 · 快照 | get_rollout_data | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(3) |
| occ-001426 | tests/plugin_contracts/test_plugin_generate_contracts.py:3 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001432 | tests/plugin_contracts/test_plugin_generate_contracts.py:143 · 快照 | test_generate_and_rm_default_generate_branch_is_stable | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run( |
| occ-001433 | tests/plugin_contracts/test_plugin_generate_contracts.py:158 · 快照 | test_generate_and_rm_prefers_per_sample_generate_function | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run(generate_and_rm(args, sample, sampling_params={“temperature”: 0.3}, evaluation=True)) |
| occ-001434 | tests/plugin_contracts/test_plugin_generate_contracts.py:169 · 快照 | test_custom_generate_function_path_supports_user_override | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run( |
| occ-001436 | tests/plugin_contracts/test_plugin_generate_contracts.py:190 · 快照 | test_generate_and_rm_group_rm_accepts_list_result_from_custom_generate | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run( |
| occ-001437 | tests/plugin_contracts/test_plugin_path_loading_contracts.py:3 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001441 | tests/plugin_contracts/test_plugin_path_loading_contracts.py:334 · 快照 | test_custom_rm_default_behavior_is_stable | api_call | asyncio.run | lexical_import_resolution | reward = asyncio.run(async_rm(make_args(rm_type=“random”), make_sample(4))) |
| occ-001442 | tests/plugin_contracts/test_plugin_path_loading_contracts.py:335 · 快照 | test_custom_rm_default_behavior_is_stable | api_call | asyncio.run | lexical_import_resolution | rewards = asyncio.run( |
| occ-001443 | tests/plugin_contracts/test_plugin_path_loading_contracts.py:347 · 快照 | test_custom_rm_path_aligns_with_expected_format | api_call | asyncio.run | lexical_import_resolution | rewards = asyncio.run( |
| occ-001444 | tests/plugin_contracts/test_plugin_path_loading_contracts.py:360 · 快照 | test_custom_rm_path_aligns_with_expected_format | api_call | asyncio.run | lexical_import_resolution | reward = asyncio.run( |
| occ-001478 | tests/test_agent/test_adapters.py:16 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001490 | tests/test_agent/test_adapters.py:201 · 快照 | test_anthropic_messages_nonstream_records_token_segments | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001499 | tests/test_agent/test_adapters.py:230 · 快照 | test_openai_chat_completions_nonstream_records_token_segments | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001509 | tests/test_agent/test_adapters.py:269 · 快照 | test_anthropic_messages_streams_blocks | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001518 | tests/test_agent/test_adapters.py:297 · 快照 | test_openai_chat_completions_streams_chunks_until_done | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001529 | tests/test_agent/test_adapters.py:375 · 快照 | test_anthropic_multiturn_wire_roundtrip_and_token_capture | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001538 | tests/test_agent/test_adapters.py:402 · 快照 | test_max_turns_per_sid_returns_429 | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001540 | tests/test_agent/test_agent_rollout_cpu.py:26 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001542 | tests/test_agent/test_agent_rollout_cpu.py:56 · 快照 | <module> | api_reference | asyncio | lexical_import_resolution | if not hasattr(asyncio, “timeout”): |
| occ-001546 | tests/test_agent/test_agent_rollout_cpu.py:62 · 快照 | <module> | api_reference | asyncio.timeout | lexical_import_resolution | asyncio.timeout = _timeout_shim |
| occ-001547 | tests/test_agent/test_agent_rollout_cpu.py:78 · 快照 | <module> | api_reference | asyncio.sleep | lexical_import_resolution | _REAL_SLEEP = asyncio.sleep |
| occ-001558 | tests/test_agent/test_agent_rollout_cpu.py:194 · 快照 | test_generate_produces_trained_samples | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case(mp)) |
| occ-001563 | tests/test_agent/test_agent_rollout_cpu.py:216 · 快照 | test_generate_aborts_on_empty_trajectory | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case(mp)) |
| occ-001567 | tests/test_agent/test_agent_rollout_cpu.py:230 · 快照 | test_generate_aborts_on_missing_image | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case(mp)) |
| occ-001577 | tests/test_agent/test_agent_rollout_cpu.py:292 · 快照 | test_codex_openai_rollout_closes_loop | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001578 | tests/test_agent/test_harness.py:14 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001579 | tests/test_agent/test_harness.py:35 · 快照 | <module> | api_reference | asyncio.sleep | lexical_import_resolution | _REAL_SLEEP = asyncio.sleep |
| occ-001585 | tests/test_agent/test_harness.py:75 · 快照 | test_run_agent_returns_marker_exit_code | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001589 | tests/test_agent/test_harness.py:88 · 快照 | test_run_agent_propagates_nonzero_exit | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001592 | tests/test_agent/test_harness.py:98 · 快照 | test_run_agent_times_out_when_marker_never_appears | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001596 | tests/test_agent/test_harness.py:115 · 快照 | test_claude_code_write_config_preacks_bypass_permissions | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001600 | tests/test_agent/test_harness.py:143 · 快照 | test_claude_code_launch_command_and_env | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001603 | tests/test_agent/test_harness.py:163 · 快照 | test_codex_write_config_base64_roundtrips_inline_base_url | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001607 | tests/test_agent/test_harness.py:186 · 快照 | test_codex_launch_command_and_env | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001610 | tests/test_agent/test_harness.py:203 · 快照 | test_ensure_agent_user_provisions_user_and_git_safe_dir | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001615 | tests/test_agent/test_harness.py:232 · 快照 | test_base_harness_run_calls_steps_in_order | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run_case()) |
| occ-001616 | tests/test_agent/test_sandbox_exec_and_wait.py:23 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001628 | tests/test_agent/test_sandbox_exec_and_wait.py:139 · 快照 | test_same_tag_reinvocation_actually_reruns | api_call | asyncio.run | lexical_import_resolution | (first_code, first_out), (second_code, second_out) = asyncio.run(_two_attempts()) |
| occ-001629 | tests/test_agent/test_sandbox_exec_and_wait.py:152 · 快照 | test_transport_retry_of_the_spawn_stays_deduped | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exec_and_wait(sb, cmd=“true”, time_budget_sec=60, tag=“job”)) |
| occ-001630 | tests/test_agent/test_sandbox_exec_and_wait.py:158 · 快照 | test_transport_retry_of_the_spawn_stays_deduped | api_call | asyncio.run | lexical_import_resolution | asyncio.run(sb.exec(spawn_cmds[0])) |
| occ-001631 | tests/test_distributed_rollout.py:3 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001661 | tests/test_distributed_rollout.py:613 · 快照 | test_slow_task_acquire_does_not_block_async_generation.exercise | api_call | asyncio.create_task | lexical_import_resolution | task = asyncio.create_task(source.get_samples_async(1)) |
| occ-001664 | tests/test_distributed_rollout.py:618 · 快照 | test_slow_task_acquire_does_not_block_async_generation.exercise | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.01) |
| occ-001669 | tests/test_distributed_rollout.py:625 · 快照 | test_slow_task_acquire_does_not_block_async_generation | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exercise()) |
| occ-001670 | tests/test_distributed_rollout.py:647 · 快照 | scheduler_factory.remote.<lambda> | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | return SimpleNamespace(remote=lambda *args: asyncio.run_coroutine_threadsafe(method(*args), loop)) |
| occ-001680 | tests/test_distributed_rollout.py:688 · 快照 | scheduler_factory.create.make_generator.execute | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.01) |
| occ-001687 | tests/test_distributed_rollout.py:735 · 快照 | scheduler_factory.cleanup | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*producers, return_exceptions=True) |
| occ-001688 | tests/test_distributed_rollout.py:737 · 快照 | scheduler_factory | api_call | asyncio.run_coroutine_threadsafe | lexical_import_resolution | asyncio.run_coroutine_threadsafe(cleanup(), loop).result(timeout=10) |
| occ-001719 | tests/test_distributed_rollout.py:963 · 快照 | test_distributed_completed_groups_keep_rewards_and_masks | api_call | asyncio.run | lexical_import_resolution | result, _ = asyncio.run(worker._generate_group(3)) |
| occ-001720 | tests/test_distributed_rollout.py:977 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results | api_call | asyncio.Event | lexical_import_resolution | release = asyncio.Event() |
| occ-001725 | tests/test_distributed_rollout.py:992 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.generate_group | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0) |
| occ-001730 | tests/test_distributed_rollout.py:1009 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.exercise | api_call | asyncio.wait_for | lexical_import_resolution | first = await asyncio.wait_for(worker._next(), timeout=5) |
| occ-001732 | tests/test_distributed_rollout.py:1010 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.exercise | api_call | asyncio.wait_for | lexical_import_resolution | second = await asyncio.wait_for(worker._next(), timeout=5) |
| occ-001735 | tests/test_distributed_rollout.py:1017 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.exercise | api_call | asyncio.wait_for | lexical_import_resolution | output = await asyncio.wait_for(worker._next(), timeout=5) |
| occ-001737 | tests/test_distributed_rollout.py:1020 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.exercise | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.02) |
| occ-001739 | tests/test_distributed_rollout.py:1022 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.exercise | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.02) |
| occ-001743 | tests/test_distributed_rollout.py:1029 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.exercise | api_call | asyncio.wait_for | lexical_import_resolution | while (output := await asyncio.wait_for(worker._next(), timeout=5)) is not None: |
| occ-001747 | tests/test_distributed_rollout.py:1037 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results.exercise | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(worker.producer, return_exceptions=True) |
| occ-001748 | tests/test_distributed_rollout.py:1039 · 快照 | test_worker_refills_locally_and_slow_group_does_not_block_results | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exercise()) |
| occ-001751 | tests/test_distributed_rollout.py:1054 · 快照 | _generate_locally | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.01) |
| occ-001753 | tests/test_distributed_rollout.py:1055 · 快照 | _generate_locally | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.01 * (sample.group_index % 3)) |
| occ-001774 | tests/test_distributed_rollout.py:1831 · 快照 | test_cancelled_rebuffer_waiter_does_not_drop_its_continuation.exercise.<comprehension> | api_call | asyncio.create_task | lexical_import_resolution | waiters = [asyncio.create_task(actor._rebuffer(i)) for i in range(130)] |
| occ-001776 | tests/test_distributed_rollout.py:1832 · 快照 | test_cancelled_rebuffer_waiter_does_not_drop_its_continuation.exercise | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.001) |
| occ-001779 | tests/test_distributed_rollout.py:1834 · 快照 | test_cancelled_rebuffer_waiter_does_not_drop_its_continuation.exercise | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*waiters, return_exceptions=True) |
| occ-001780 | tests/test_distributed_rollout.py:1839 · 快照 | test_cancelled_rebuffer_waiter_does_not_drop_its_continuation | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exercise()) |
| occ-001800 | tests/test_distributed_rollout.py:2072 · 快照 | test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run | api_call | asyncio.Event | lexical_import_resolution | entered, release = asyncio.Event(), asyncio.Event() |
| occ-001801 | tests/test_distributed_rollout.py:2072 · 快照 | test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run | api_call | asyncio.Event | lexical_import_resolution | entered, release = asyncio.Event(), asyncio.Event() |
| occ-001808 | tests/test_distributed_rollout.py:2094 · 快照 | test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run | api_call | asyncio.create_task | lexical_import_resolution | task = asyncio.create_task(worker._generate_group(0)) |
| occ-001814 | tests/test_distributed_rollout.py:2103 · 快照 | test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run()) |
| occ-001823 | tests/test_fully_async_rollout.py:21 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001827 | tests/test_fully_async_rollout.py:70 · 快照 | test_custom_data_source_keeps_original_entrypoint | api_reference | asyncio.run | lexical_import_resolution | monkeypatch.setattr(fa, “run”, asyncio.run) |
| occ-001829 | tests/test_fully_async_rollout.py:118 · 快照 | test_rollout_takes_target_groups_and_leaves_surplus_queued | api_call | asyncio.run | lexical_import_resolution | out = asyncio.run(fa._generate_rollout_async(args, rollout_id=0, data_buffer=None)) |
| occ-001832 | tests/test_fully_async_rollout.py:166 · 快照 | test_dynamic_filter_drops_groups_and_refills | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run(fa._generate_rollout_async(args, rollout_id=7, data_buffer=None)) |
| occ-001843 | tests/test_fully_async_rollout.py:267 · 快照 | test_local_worker_lifecycle_is_scoped_to_source.generate | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.01) |
| occ-001862 | tests/test_published_payload_retry.py:3 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001869 | tests/test_published_payload_retry.py:42 · 快照 | test_result_and_shelve_payloads_recover_at_the_storage_layer | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run(transport.unpack_published_payload(ref)) |
| occ-001871 | tests/test_published_payload_retry.py:64 · 快照 | test_native_failure_is_not_retried_again_by_slime | api_call | asyncio.run | lexical_import_resolution | asyncio.run(transport.unpack_published_payload(ref)) |
| occ-001935 | tests/test_rollout_sample_hooks.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001937 | tests/test_rollout_sample_hooks.py:34 · 快照 | test_rollout_sample_hooks_preserve_nested_shape_and_filter_kwargs | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run(apply_rollout_sample_hooks(args, samples, evaluation=True, ignored=“value”)) |
| occ-001938 | tests/test_rollout_sample_hooks.py:47 · 快照 | test_rollout_sample_hook_rejects_invalid_return_type | api_call | asyncio.run | lexical_import_resolution | asyncio.run(apply_rollout_sample_hooks(args, Sample(index=0))) |
| occ-001939 | tests/test_rollout_sample_hooks.py:55 · 快照 | test_rollout_sample_hooks_are_noop_when_unconfigured | api_call | asyncio.run | lexical_import_resolution | assert asyncio.run(apply_rollout_sample_hooks(args, sample)) is sample |
| occ-001942 | tests/test_rollout_sample_hooks.py:63 · 快照 | test_concurrent_groups_keep_their_own_rollout_hook_context.generate | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0) |
| occ-001946 | tests/test_rollout_sample_hooks.py:68 · 快照 | test_concurrent_groups_keep_their_own_rollout_hook_context.exercise | api_call | asyncio.gather | lexical_import_resolution | assert await asyncio.gather(generate(10), generate(11)) == [(“seen”, 10), (“seen”, 11)] |
| occ-001947 | tests/test_rollout_sample_hooks.py:70 · 快照 | test_concurrent_groups_keep_their_own_rollout_hook_context | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exercise()) |
| occ-001951 | tests/test_rollout_straw_transport.py:329 · 快照 | test_fully_async_stores_groups_while_collecting_the_batch | import | asyncio | explicit_import | import asyncio |
| occ-001952 | tests/test_rollout_straw_transport.py:354 · 快照 | test_fully_async_stores_groups_while_collecting_the_batch | api_call | asyncio.run | lexical_import_resolution | output = asyncio.run(fa._generate_rollout_async(args, 0, None)) |
| occ-001953 | tests/test_rollout_straw_transport.py:362 · 快照 | test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook | import | asyncio | explicit_import | import asyncio |
| occ-001955 | tests/test_rollout_straw_transport.py:376 · 快照 | test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise | api_call | asyncio.Event | lexical_import_resolution | second = asyncio.Event() |
| occ-001956 | tests/test_rollout_straw_transport.py:377 · 快照 | test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise | api_call | asyncio.get_running_loop | lexical_import_resolution | loop = asyncio.get_running_loop() |
| occ-001960 | tests/test_rollout_straw_transport.py:387 · 快照 | test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise.submit.<comprehension> | api_call | asyncio.create_task | lexical_import_resolution | state.pendings.update(asyncio.create_task(generate(index)) for index in (2, 1)) |
| occ-001964 | tests/test_rollout_straw_transport.py:409 · 快照 | test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise | api_call | asyncio.wait_for | lexical_import_resolution | return await asyncio.wait_for(sr.generate_rollout_async(args, 0, lambda count: [None] * count), timeout=20) |
| occ-001965 | tests/test_rollout_straw_transport.py:411 · 快照 | test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook | api_call | asyncio.run | lexical_import_resolution | output, aborted = asyncio.run(exercise()) |
| occ-001983 | tests/test_score_centering_binary.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001990 | tests/test_score_centering_binary.py:121 · 快照 | test_http_worker_decodes_off_event_loop | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run( |
| occ-001991 | tests/test_score_centering_transport.py:3 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-001993 | tests/test_score_centering_transport.py:93 · 快照 | test_generate_requests_sampler_topk | api_call | asyncio.run | lexical_import_resolution | sample = asyncio.run(rollout.generate(a, Sample(prompt=“test”), {“max_new_tokens”: 8})) |
| occ-001995 | tests/test_score_centering_transport.py:145 · 快照 | test_r3_resume_appends_routes_without_replacing_the_persisted_prefix | api_call | asyncio.run | lexical_import_resolution | asyncio.run(rollout.generate(a, sample, {“max_new_tokens”: 8})) |
| occ-001996 | tests/test_score_centering_transport.py:148 · 快照 | test_r3_resume_appends_routes_without_replacing_the_persisted_prefix | api_call | asyncio.run | lexical_import_resolution | actual = asyncio.run(rollout.generate(a, sample, {“max_new_tokens”: 8})) |
| occ-001997 | tests/test_score_centering_transport.py:159 · 快照 | test_streaming_score_centering_rejected | api_call | asyncio.run | lexical_import_resolution | asyncio.run(generate_streaming(args(), Sample(), {})) |
| occ-001998 | tests/test_score_centering_transport.py:191 · 快照 | test_evaluation_preserves_training_score_centering | api_call | asyncio.Semaphore | lexical_import_resolution | semaphore=asyncio.Semaphore(1), |
| occ-002004 | tests/test_score_centering_transport.py:219 · 快照 | test_evaluation_preserves_training_score_centering | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run()) |
| occ-002006 | tests/test_score_centering_transport.py:561 · 快照 | test_generate_requests_complete_top_p_probabilities | api_call | asyncio.run | lexical_import_resolution | sample = asyncio.run(rollout.generate(a, Sample(prompt=“test”), {“max_new_tokens”: 8})) |
| occ-002007 | tests/test_server_control.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-002009 | tests/test_server_control.py:37 · 快照 | test_rollout_boundary_prunes_failed_router_workers | api_call | asyncio.run | lexical_import_resolution | workers = asyncio.run(server_control.get_live_router_workers(“http://router”, timeout=0.1)) |
| occ-002014 | tests/test_server_control.py:139 · 快照 | test_abort_uses_supported_load_sections_and_waits_for_pd_transfers | api_call | asyncio.run | lexical_import_resolution | asyncio.run(server_control.abort_server_until_idle(“http://engine”, retry_interval=0, timeout=0.1)) |
| occ-002017 | tests/test_server_control.py:181 · 快照 | test_abort_retries_load_failure_until_idle | api_call | asyncio.run | lexical_import_resolution | asyncio.run(server_control.abort_server_until_idle(“http://engine”, retry_interval=0, timeout=1)) |
| occ-002019 | tests/test_server_control.py:193 · 快照 | test_abort_servers_surfaces_partial_failure | api_call | asyncio.run | lexical_import_resolution | asyncio.run(server_control.abort_servers_until_idle([“http://good”, “http://bad”])) |
| occ-002023 | tests/test_server_control.py:218 · 快照 | test_http_post_forwards_timeout_and_closes_response | api_call | asyncio.run | lexical_import_resolution | assert asyncio.run(http_utils._post(Client(), “http://engine”, {}, max_retries=1, timeout=2.5)) == {“ok”: True} |
| occ-002026 | tests/test_server_control.py:232 · 快照 | test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve | api_call | asyncio.current_task | lexical_import_resolution | task = asyncio.current_task() |
| occ-002032 | tests/test_server_control.py:250 · 快照 | test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.1) |
| occ-002036 | tests/test_server_control.py:253 · 快照 | test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serve | api_reference | asyncio.IncompleteReadError | lexical_import_resolution | except (asyncio.IncompleteReadError, ConnectionError): |
| occ-002041 | tests/test_server_control.py:261 · 快照 | test_http_transport_preserves_streams_timeouts_and_connection_budget.check | api_call | asyncio.start_server | lexical_import_resolution | server = await asyncio.start_server(serve, “127.0.0.1”, 0, backlog=2 * concurrency) |
| occ-002047 | tests/test_server_control.py:272 · 快照 | test_http_transport_preserves_streams_timeouts_and_connection_budget.check | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*(request(i) for i in range(concurrency + 3))) |
| occ-002054 | tests/test_server_control.py:281 · 快照 | test_http_transport_preserves_streams_timeouts_and_connection_budget.check | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*tasks, return_exceptions=True) |
| occ-002055 | tests/test_server_control.py:284 · 快照 | test_http_transport_preserves_streams_timeouts_and_connection_budget | api_call | asyncio.run | lexical_import_resolution | asyncio.run(check()) |
| occ-002056 | tests/test_straw_fully_async_recovery.py:9 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-002064 | tests/test_straw_fully_async_recovery.py:49 · 快照 | _generate_with_interrupt | api_call | asyncio.Event | lexical_import_resolution | await asyncio.Event().wait() |
| occ-002067 | tests/test_straw_fully_async_recovery.py:52 · 快照 | _generate_with_interrupt | api_call | asyncio.Event | lexical_import_resolution | await asyncio.Event().wait() |
| occ-002091 | tests/test_straw_r3.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-002093 | tests/test_straw_r3.py:61 · 快照 | test_straw_publishes_replay_tensors_with_the_group_without_hook_or_spill_directory | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run(apply_rollout_sample_hooks(args, nested, rollout_id=3)) |
| occ-002094 | tests/test_straw_r3.py:105 · 快照 | test_hooks_leave_ray_evaluation_and_aborted_samples_resident | api_call | asyncio.run | lexical_import_resolution | assert asyncio.run(apply_rollout_sample_hooks(args, sample, evaluation=evaluation)) is sample |
| occ-002100 | tests/test_straw_r3.py:160 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity.run | api_call | asyncio.create_task | lexical_import_resolution | first = asyncio.create_task(rollout_transport.publish_rollout_async(samples[0], args, 0)) |
| occ-002102 | tests/test_straw_r3.py:163 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity.run | api_call | asyncio.to_thread | lexical_import_resolution | assert await asyncio.to_thread(entered.wait, 5) |
| occ-002104 | tests/test_straw_r3.py:165 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity.run | api_call | asyncio.create_task | lexical_import_resolution | second = asyncio.create_task(rollout_transport.publish_rollout_async(samples[1], args, 0)) |
| occ-002106 | tests/test_straw_r3.py:167 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity.run | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.05) |
| occ-002109 | tests/test_straw_r3.py:169 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity.run | api_call | asyncio.sleep | lexical_import_resolution | await asyncio.sleep(0.05) |
| occ-002113 | tests/test_straw_r3.py:174 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity.run | api_call | asyncio.gather | lexical_import_resolution | results = await asyncio.gather(*tasks, return_exceptions=True) |
| occ-002114 | tests/test_straw_r3.py:175 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity.run | api_reference | asyncio.CancelledError | lexical_import_resolution | assert isinstance(results[0], asyncio.CancelledError) |
| occ-002115 | tests/test_straw_r3.py:179 · 快照 | test_cancelled_straw_publication_drains_before_releasing_capacity | api_call | asyncio.run | lexical_import_resolution | asyncio.run(run()) |
| occ-002117 | tests/test_streaming_rollout.py:1 · 快照 | <module> | import | asyncio | explicit_import | import asyncio |
| occ-002121 | tests/test_streaming_rollout.py:129 · 快照 | _generation_state | api_call | asyncio.Semaphore | lexical_import_resolution | semaphore=asyncio.Semaphore(8), |
| occ-002128 | tests/test_streaming_rollout.py:258 · 快照 | test_generate_streaming_preserves_metadata_across_stream_intervals | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run( |
| occ-002129 | tests/test_streaming_rollout.py:299 · 快照 | test_generate_streaming_handles_encoded_terminal_metadata | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run( |
| occ-002130 | tests/test_streaming_rollout.py:320 · 快照 | test_streaming_generator_fails_closed_on_unexpected_eof | api_call | asyncio.run | lexical_import_resolution | asyncio.run( |
| occ-002133 | tests/test_streaming_rollout.py:338 · 快照 | test_server_abort_keeps_last_observed_prefix | api_call | asyncio.run | lexical_import_resolution | result = asyncio.run( |
| occ-002134 | tests/test_streaming_rollout.py:352 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix | api_call | asyncio.Event | lexical_import_resolution | first_chunk_seen = asyncio.Event() |
| occ-002135 | tests/test_streaming_rollout.py:353 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix | api_call | asyncio.Event | lexical_import_resolution | request_closed = asyncio.Event() |
| occ-002136 | tests/test_streaming_rollout.py:354 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix | api_call | asyncio.Event | lexical_import_resolution | server_started = asyncio.Event() |
| occ-002137 | tests/test_streaming_rollout.py:355 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix | api_call | asyncio.Event | lexical_import_resolution | server_released = asyncio.Event() |
| occ-002142 | tests/test_streaming_rollout.py:369 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix.lines | api_call | asyncio.Event | lexical_import_resolution | await asyncio.Event().wait() |
| occ-002152 | tests/test_streaming_rollout.py:393 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix.exercise | api_call | asyncio.create_task | lexical_import_resolution | request_task = asyncio.create_task( |
| occ-002153 | tests/test_streaming_rollout.py:400 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix.exercise | api_call | asyncio.create_task | lexical_import_resolution | server_task = asyncio.create_task(sglang_rollout.generate_and_rm(args, Sample(), {})) |
| occ-002155 | tests/test_streaming_rollout.py:401 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix.exercise | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(first_chunk_seen.wait(), server_started.wait()) |
| occ-002160 | tests/test_streaming_rollout.py:403 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix.exercise | api_call | asyncio.gather | lexical_import_resolution | return await asyncio.gather(request_task, server_task) |
| occ-002161 | tests/test_streaming_rollout.py:405 · 快照 | test_stream_cancellation_closes_request_and_keeps_prefix | api_call | asyncio.run | lexical_import_resolution | result, server_result = asyncio.run(exercise()) |
| occ-002163 | tests/test_streaming_rollout.py:416 · 快照 | test_unrelated_stream_cancellation_propagates | api_call | asyncio.Event | lexical_import_resolution | request_started = asyncio.Event() |
| occ-002167 | tests/test_streaming_rollout.py:421 · 快照 | test_unrelated_stream_cancellation_propagates.lines | api_call | asyncio.Event | lexical_import_resolution | await asyncio.Event().wait() |
| occ-002171 | tests/test_streaming_rollout.py:428 · 快照 | test_unrelated_stream_cancellation_propagates.exercise | api_call | asyncio.create_task | lexical_import_resolution | task = asyncio.create_task( |
| occ-002175 | tests/test_streaming_rollout.py:438 · 快照 | test_unrelated_stream_cancellation_propagates.exercise | api_reference | asyncio.CancelledError | lexical_import_resolution | with pytest.raises(asyncio.CancelledError): |
| occ-002177 | tests/test_streaming_rollout.py:441 · 快照 | test_unrelated_stream_cancellation_propagates | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exercise()) |
| occ-002179 | tests/test_streaming_rollout.py:472 · 快照 | test_partial_abort_buffers_and_resumes_only_aborted_siblings.exercise.<comprehension> | api_call | asyncio.create_task | lexical_import_resolution | asyncio.create_task(asyncio.sleep(0, result=group)) for group in (mixed_group, [terminal], [empty]) |
| occ-002180 | tests/test_streaming_rollout.py:472 · 快照 | test_partial_abort_buffers_and_resumes_only_aborted_siblings.exercise.<comprehension> | api_call | asyncio.sleep | lexical_import_resolution | asyncio.create_task(asyncio.sleep(0, result=group)) for group in (mixed_group, [terminal], [empty]) |
| occ-002184 | tests/test_streaming_rollout.py:507 · 快照 | test_partial_abort_buffers_and_resumes_only_aborted_siblings.exercise | api_call | asyncio.Semaphore | lexical_import_resolution | state.semaphore = asyncio.Semaphore(2) |
| occ-002186 | tests/test_streaming_rollout.py:514 · 快照 | test_partial_abort_buffers_and_resumes_only_aborted_siblings | api_call | asyncio.run | lexical_import_resolution | buffered_groups, resumed_group = asyncio.run(exercise()) |
| occ-002188 | tests/test_streaming_rollout.py:535 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.Semaphore | lexical_import_resolution | state.semaphore = asyncio.Semaphore(128) |
| occ-002189 | tests/test_streaming_rollout.py:539 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.Event | lexical_import_resolution | first_batch, all_started, finish = asyncio.Event(), asyncio.Event(), asyncio.Event() |
| occ-002190 | tests/test_streaming_rollout.py:539 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.Event | lexical_import_resolution | first_batch, all_started, finish = asyncio.Event(), asyncio.Event(), asyncio.Event() |
| occ-002191 | tests/test_streaming_rollout.py:539 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.Event | lexical_import_resolution | first_batch, all_started, finish = asyncio.Event(), asyncio.Event(), asyncio.Event() |
| occ-002192 | tests/test_streaming_rollout.py:541 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.get_running_loop | lexical_import_resolution | loop = asyncio.get_running_loop() |
| occ-002198 | tests/test_streaming_rollout.py:568 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise.start | api_call | asyncio.create_task | lexical_import_resolution | return asyncio.create_task( |
| occ-002200 | tests/test_streaming_rollout.py:573 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.wait_for | lexical_import_resolution | await asyncio.wait_for(first_batch.wait(), 1) |
| occ-002204 | tests/test_streaming_rollout.py:578 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_reference | asyncio.CancelledError | lexical_import_resolution | with pytest.raises(asyncio.CancelledError): |
| occ-002207 | tests/test_streaming_rollout.py:581 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.wait_for | lexical_import_resolution | await asyncio.wait_for(all_started.wait(), 1) |
| occ-002211 | tests/test_streaming_rollout.py:585 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise | api_call | asyncio.gather | lexical_import_resolution | await asyncio.gather(*(task for i, task in enumerate(tasks) if i != 70)) |
| occ-002213 | tests/test_streaming_rollout.py:589 · 快照 | test_generation_pacing_preserves_concurrency_cancellation_and_reuse | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exercise()) |
| occ-002215 | tests/test_streaming_rollout.py:597 · 快照 | test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise | api_call | asyncio.Event | lexical_import_resolution | queued, release = asyncio.Event(), asyncio.Event() |
| occ-002216 | tests/test_streaming_rollout.py:597 · 快照 | test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise | api_call | asyncio.Event | lexical_import_resolution | queued, release = asyncio.Event(), asyncio.Event() |
| occ-002223 | tests/test_streaming_rollout.py:611 · 快照 | test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise | api_call | asyncio.create_task | lexical_import_resolution | task = asyncio.create_task(sglang_rollout.generate_and_rm(args, Sample(), {})) |
| occ-002228 | tests/test_streaming_rollout.py:618 · 快照 | test_abort_while_waiting_for_generation_pacer_does_not_start_request | api_call | asyncio.run | lexical_import_resolution | asyncio.run(exercise()) |