相关文件中的实例方法候选；即使有构造或注解证据，也不并入原生 API 计数。

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

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

总览 · 完整文件索引 · JSON · TSV

ID位置 / 快照所属符号种类API / 语法来源判定源码行
occ-000010examples/coding_agent_rl/generate.py:109 · 快照boot_agent_sandboxinstance_candidateaenterunresolved_receiver_candidateawait cand.aenter()
occ-000013examples/coding_agent_rl/generate.py:113 · 快照boot_agent_sandboxinstance_candidateaexitunresolved_receiver_candidateawait cand.aexit(None, None, None)
occ-000018examples/coding_agent_rl/generate.py:134 · 快照boot_agent_sandboxinstance_candidateaexitunresolved_receiver_candidateawait sb.aexit(None, None, None)
occ-000033examples/coding_agent_rl/generate.py:290 · 快照_log_timeout_diagnostic.<comprehension>instance_candidatedoneunresolved_receiver_candidatepending = [t for t in asyncio.all_tasks() if not t.done()]
occ-000035examples/coding_agent_rl/swe.py:91 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidaterem = m.get(“remote_env_info”) or {}
occ-000036examples/coding_agent_rl/swe.py:93 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidateswepro = m.get(“swepro”)
occ-000037examples/coding_agent_rl/swe.py:94 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidateeval_cmd = m.get(“eval_cmd”)
occ-000038examples/coding_agent_rl/swe.py:95 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidatef2p_script = rem.get(“f2p_script”)
occ-000039examples/coding_agent_rl/swe.py:96 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidatelooks_swebench = bool(rem.get(“test_patch”)) and not (swepro or eval_cmd or f2p_script)
occ-000040examples/coding_agent_rl/swe.py:99 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“instance_id”: m.get(“instance_id”) or rem.get(“instance_id”) or label or “unknown”,
occ-000041examples/coding_agent_rl/swe.py:99 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“instance_id”: m.get(“instance_id”) or rem.get(“instance_id”) or label or “unknown”,
occ-000042examples/coding_agent_rl/swe.py:100 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“image”: m.get(“image”) or rem.get(“image_url”),
occ-000043examples/coding_agent_rl/swe.py:100 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“image”: m.get(“image”) or rem.get(“image_url”),
occ-000044examples/coding_agent_rl/swe.py:101 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“workdir”: m.get(“workdir”) or rem.get(“workdir”),
occ-000045examples/coding_agent_rl/swe.py:101 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“workdir”: m.get(“workdir”) or rem.get(“workdir”),
occ-000046examples/coding_agent_rl/swe.py:102 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“problem_statement”: m.get(“problem_statement”) or _coerce_prompt(sample.prompt),
occ-000047examples/coding_agent_rl/swe.py:108 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“pre_commands”: m.get(“pre_commands”) or rem.get(“pre_commands”),
occ-000048examples/coding_agent_rl/swe.py:108 · 快照_metadata_scalesweinstance_candidategetunresolved_receiver_candidate“pre_commands”: m.get(“pre_commands”) or rem.get(“pre_commands”),
occ-000049examples/coding_agent_rl/swe.py:117 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidaterem = m.get(“remote_env_info”) or {}
occ-000050examples/coding_agent_rl/swe.py:119 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“instance_id”: rem.get(“instance_id”) or “unknown”,
occ-000051examples/coding_agent_rl/swe.py:120 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“repo”: rem.get(“repo”) or “”,
occ-000052examples/coding_agent_rl/swe.py:121 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“version”: rem.get(“version”),
occ-000053examples/coding_agent_rl/swe.py:122 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“base_commit”: rem.get(“base_commit”) or “”,
occ-000054examples/coding_agent_rl/swe.py:123 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“problem_statement”: rem.get(“problem_statement”) or _coerce_prompt(sample.prompt),
occ-000055examples/coding_agent_rl/swe.py:124 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“hints_text”: rem.get(“hints_text”) or “”,
occ-000056examples/coding_agent_rl/swe.py:125 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“test_patch”: rem.get(“test_patch”) or “”,
occ-000057examples/coding_agent_rl/swe.py:126 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“FAIL_TO_PASS”: rem.get(“FAIL_TO_PASS”),
occ-000058examples/coding_agent_rl/swe.py:127 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“PASS_TO_PASS”: rem.get(“PASS_TO_PASS”),
occ-000059examples/coding_agent_rl/swe.py:128 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“environment_setup_commit”: rem.get(“environment_setup_commit”),
occ-000060examples/coding_agent_rl/swe.py:133 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“image”: rem.get(“image”),
occ-000061examples/coding_agent_rl/swe.py:134 · 快照_metadata_swebenchinstance_candidategetunresolved_receiver_candidate“workdir”: rem.get(“workdir”) or “/testbed”,
occ-000062examples/coding_agent_rl/swe.py:146 · 快照_coerce_promptinstance_candidategetunresolved_receiver_candidateif isinstance(m, dict) and m.get(“role”) == “user”:
occ-000063examples/coding_agent_rl/swe.py:147 · 快照_coerce_promptinstance_candidategetunresolved_receiver_candidatereturn flatten_content(m.get(“content”))
occ-000064examples/coding_agent_rl/swe.py:152 · 快照evaluability_checkinstance_candidategetunresolved_receiver_candidateif md.get(“protocol”) == PROTOCOL_SWEBENCH:
occ-000065examples/coding_agent_rl/swe.py:154 · 快照evaluability_checkinstance_candidategetunresolved_receiver_candidatereturn “protocol_row_mismatch:looks_swebench” if md.get(“looks_swebench”) else None
occ-000066examples/coding_agent_rl/swe.py:160 · 快照_evaluability_check_swebenchinstance_candidategetunresolved_receiver_candidateinst = md.get(“grading”, {}).get(“sweb_instance”) or {}
occ-000067examples/coding_agent_rl/swe.py:160 · 快照_evaluability_check_swebenchinstance_candidategetunresolved_receiver_candidateinst = md.get(“grading”, {}).get(“sweb_instance”) or {}
occ-000068examples/coding_agent_rl/swe.py:161 · 快照_evaluability_check_swebenchinstance_candidategetunresolved_receiver_candidateif not inst.get(“repo”):
occ-000069examples/coding_agent_rl/swe.py:163 · 快照_evaluability_check_swebenchinstance_candidategetunresolved_receiver_candidateif not inst.get(“base_commit”):
occ-000070examples/coding_agent_rl/swe.py:165 · 快照_evaluability_check_swebenchinstance_candidategetunresolved_receiver_candidateif not (inst.get(“test_patch”) or “”).strip():
occ-000073examples/coding_agent_rl/swe.py:186 · 快照prepare_workspaceinstance_candidategetunresolved_receiver_candidateif md.get(“protocol”) == PROTOCOL_SCALESWE:
occ-000074examples/coding_agent_rl/swe.py:187 · 快照prepare_workspaceinstance_candidategetunresolved_receiver_candidategrading = md.get(“grading”) or {}
occ-000075examples/coding_agent_rl/swe.py:188 · 快照prepare_workspaceinstance_candidategetunresolved_receiver_candidateswepro = grading.get(“swepro”)
occ-000077examples/coding_agent_rl/swe.py:191 · 快照prepare_workspaceinstance_candidategetunresolved_receiver_candidatepre_commands = grading.get(“pre_commands”)
occ-000080examples/coding_agent_rl/swe.py:196 · 快照prepare_workspaceinstance_candidategetunresolved_receiver_candidatemd.get(“problem_statement”) or “”,
occ-000082examples/coding_agent_rl/swe.py:203 · 快照apply_before_repo_set_cmdinstance_candidategetunresolved_receiver_candidatebefore = swepro.get(“before_repo_set_cmd”)
occ-000087examples/coding_agent_rl/swe.py:222 · 快照apply_pre_commandsinstance_candidatejoinunresolved_receiver_candidatebody = “\n”.join(c for c in (pre or []) if c)
occ-000093examples/coding_agent_rl/swe.py:245 · 快照run_evaluationinstance_candidategetunresolved_receiver_candidateif md.get(“protocol”) == PROTOCOL_SWEBENCH:
occ-000097examples/coding_agent_rl/swe.py:259 · 快照_grade_scalesweinstance_candidategetunresolved_receiver_candidategrading = md.get(“grading”) or {}
occ-000098examples/coding_agent_rl/swe.py:260 · 快照_grade_scalesweinstance_candidategetunresolved_receiver_candidateswepro = grading.get(“swepro”)
occ-000099examples/coding_agent_rl/swe.py:261 · 快照_grade_scalesweinstance_candidategetunresolved_receiver_candidateeval_cmd = grading.get(“eval_cmd”)
occ-000100examples/coding_agent_rl/swe.py:262 · 快照_grade_scalesweinstance_candidategetunresolved_receiver_candidatef2p_script = grading.get(“f2p_script”)
occ-000101examples/coding_agent_rl/swe.py:263 · 快照_grade_scalesweinstance_candidategetunresolved_receiver_candidatepre_commands = grading.get(“pre_commands”)
occ-000113examples/coding_agent_rl/swe.py:293 · 快照_setup_swepro_assetsinstance_candidategetunresolved_receiver_candidatehost_p = swepro.get(k)
occ-000118examples/coding_agent_rl/swe.py:304 · 快照_apply_diffinstance_candidatejoinunresolved_receiver_candidateladder = " || “.join(
occ-000121examples/coding_agent_rl/swe.py:317 · 快照_run_sweproinstance_candidatejoinunresolved_receiver_candidatetest_arg = “,".join(swepro.get(“selected_test_files”) or [])
occ-000122examples/coding_agent_rl/swe.py:317 · 快照_run_sweproinstance_candidategetunresolved_receiver_candidatetest_arg = “,".join(swepro.get(“selected_test_files”) or [])
occ-000126examples/coding_agent_rl/swe.py:335 · 快照_run_sweproinstance_candidategetunresolved_receiver_candidatepassed = {t[“name”] for t in parsed.get(“tests”, []) if t.get(“status”) == “PASSED”}
occ-000127examples/coding_agent_rl/swe.py:335 · 快照_run_swepro.<comprehension>instance_candidategetunresolved_receiver_candidatepassed = {t[“name”] for t in parsed.get(“tests”, []) if t.get(“status”) == “PASSED”}
occ-000128examples/coding_agent_rl/swe.py:336 · 快照_run_sweproinstance_candidategetunresolved_receiver_candidaterequired = set(swepro.get(“fail_to_pass”) or []) | set(swepro.get(“pass_to_pass”) or [])
occ-000129examples/coding_agent_rl/swe.py:336 · 快照_run_sweproinstance_candidategetunresolved_receiver_candidaterequired = set(swepro.get(“fail_to_pass”) or []) | set(swepro.get(“pass_to_pass”) or [])
occ-000136examples/coding_agent_rl/swe.py:368 · 快照_apply_model_patchinstance_candidatejoinunresolved_receiver_candidateladder = " || “.join(f”{cmd} /tmp/patch.diff” for cmd in _GIT_APPLY_CMDS)
occ-000138examples/coding_agent_rl/swe.py:388 · 快照_eval_report_from_loginstance_candidatewriteunresolved_receiver_candidatetmp.write(log)
occ-000139examples/coding_agent_rl/swe.py:390 · 快照_eval_report_from_loginstance_candidatecloseunresolved_receiver_candidatetmp.close()
occ-000140examples/coding_agent_rl/swe.py:411 · 快照_ratioinstance_candidategetunresolved_receiver_candidatepassed, failed = d.get(“success”, []), d.get(“failure”, [])
occ-000141examples/coding_agent_rl/swe.py:411 · 快照_ratioinstance_candidategetunresolved_receiver_candidatepassed, failed = d.get(“success”, []), d.get(“failure”, [])
occ-000142examples/coding_agent_rl/swe.py:419 · 快照_log_swebench_resultinstance_candidategetunresolved_receiver_candidateif info.get(“resolved”):
occ-000143examples/coding_agent_rl/swe.py:422 · 快照_log_swebench_resultinstance_candidategetunresolved_receiver_candidatets_status = info.get(“tests_status”) or {}
occ-000144examples/coding_agent_rl/swe.py:423 · 快照_log_swebench_resultinstance_candidategetunresolved_receiver_candidatef2p_pass, f2p_total = _ratio(ts_status.get(“FAIL_TO_PASS”, {}))
occ-000145examples/coding_agent_rl/swe.py:424 · 快照_log_swebench_resultinstance_candidategetunresolved_receiver_candidatep2p_pass, p2p_total = _ratio(ts_status.get(“PASS_TO_PASS”, {}))
occ-000146examples/coding_agent_rl/swe.py:431 · 快照_log_swebench_resultinstance_candidategetunresolved_receiver_candidatebool(info.get(“patch_successfully_applied”)),
occ-000153examples/coding_agent_rl/swe.py:490 · 快照_grade_swebenchinstance_candidategetunresolved_receiver_candidateinfo = report.get(instance_id, {})
occ-000154examples/coding_agent_rl/swe.py:492 · 快照_grade_swebenchinstance_candidategetunresolved_receiver_candidatereturn EvalResult(1.0 if info.get(“resolved”) else 0.0, bool(info.get(“patch_successfully_applied”)))
occ-000155examples/coding_agent_rl/swe.py:492 · 快照_grade_swebenchinstance_candidategetunresolved_receiver_candidatereturn EvalResult(1.0 if info.get(“resolved”) else 0.0, bool(info.get(“patch_successfully_applied”)))
occ-000156examples/geo3k_vlm_multi_turn/rollout.py:66 · 快照_encode_observation_for_generationinstance_candidategetunresolved_receiver_candidatetools = metadata.get(“tools”) if metadata else None
occ-000157examples/geo3k_vlm_multi_turn/rollout.py:110 · 快照_encode_observation_for_generationinstance_candidategetunresolved_receiver_candidateif multimodal_inputs and multimodal_inputs.get(“images”):
occ-000158examples/geo3k_vlm_multi_turn/rollout.py:165 · 快照_prepare_initial_inputsinstance_candidategetunresolved_receiver_candidateif sample.multimodal_inputs and sample.multimodal_inputs.get(“images”):
occ-000159examples/geo3k_vlm_multi_turn/rollout.py:187 · 快照_prepare_start_stateinstance_candidategetunresolved_receiver_candidateelif sampling_params.get(“max_new_tokens”) is not None:
occ-000163examples/geo3k_vlm_multi_turn/rollout.py:325 · 快照generateinstance_candidateresetunresolved_receiver_candidateenv.reset()
occ-000165examples/geo3k_vlm_multi_turn/rollout.py:385 · 快照generateinstance_candidatecloseunresolved_receiver_candidateenv.close()
occ-000193examples/retool/generate_with_retool.py:120 · 快照postprocess_predictionsinstance_candidategetunresolved_receiver_candidatetool_name = tool_call_data.get(“name”)
occ-000194examples/retool/generate_with_retool.py:121 · 快照postprocess_predictionsinstance_candidategetunresolved_receiver_candidatearguments = tool_call_data.get(“arguments”, {})
occ-000195examples/retool/generate_with_retool.py:124 · 快照postprocess_predictionsinstance_candidategetunresolved_receiver_candidatecode = arguments.get(“code”, “”)
occ-000200examples/retool/generate_with_retool.py:266 · 快照generateinstance_candidategetunresolved_receiver_candidatesampling_params.get(“max_new_tokens”, remaining_budget),
occ-000208examples/retool/tool_sandbox.py:209 · 快照PythonSandbox.execute_codeinstance_candidatejoinunresolved_receiver_candidateindented_code = “\n”.join(” " + line for line in code.split("\n”))
occ-000209examples/retool/tool_sandbox.py:263 · 快照PythonSandbox.execute_codeinstance_candidatewriteunresolved_receiver_candidatef.write(wrapped_code)
occ-000213examples/retool/tool_sandbox.py:278 · 快照PythonSandbox.execute_codeinstance_candidatecommunicateinferred_receiver_candidate; subprocess.Popen @ L267stdout, stderr = process.communicate(timeout=self.timeout)
occ-000215examples/retool/tool_sandbox.py:286 · 快照PythonSandbox.execute_codeinstance_candidatekillinferred_receiver_candidate; subprocess.Popen @ L267process.kill()
occ-000220examples/retool/tool_sandbox.py:350 · 快照ToolRegistry._execute_pythoninstance_candidategetunresolved_receiver_candidatecode = arguments.get(“code”, “”)
occ-000224examples/search-r1/generate_with_search.py:53 · 快照_passages2stringinstance_candidatejoinunresolved_receiver_candidatetext = “\n”.join(content.split("\n")[1:])
occ-000232examples/search-r1/generate_with_search.py:174 · 快照generateinstance_candidategetunresolved_receiver_candidate_existing_stop = sampling_params.get(“stop”) or []
occ-000237examples/search-r1/google_search_server.py:33 · 快照filter_linksinstance_candidategetunresolved_receiver_candidatefor item in result.get(“items”, []):
occ-000242examples/search-r1/google_search_server.py:54 · 快照fetchinstance_candidategetunresolved_receiver_candidateasync with session.get(url, headers=headers) as response:
occ-000244examples/search-r1/google_search_server.py:55 · 快照fetchinstance_candidatereadunresolved_receiver_candidateraw = await response.read()
occ-000251examples/search-r1/google_search_server.py:91 · 快照collect_contextinstance_candidatejoinunresolved_receiver_candidatereturn “\n”.join(ctx_paras)
occ-000256examples/search-r1/google_search_server.py:116 · 快照google_searchinstance_candidategetunresolved_receiver_candidateitems = response.get(“organic”, [])
occ-000257examples/search-r1/google_search_server.py:121 · 快照google_searchinstance_candidategetunresolved_receiver_candidatetitle = item.get(“title”, “”)
occ-000258examples/search-r1/google_search_server.py:122 · 快照google_searchinstance_candidatejoinunresolved_receiver_candidatecontext = " “.join(parse_snippet(item.get(“snippet”, “”)))
occ-000259examples/search-r1/google_search_server.py:122 · 快照google_searchinstance_candidategetunresolved_receiver_candidatecontext = " “.join(parse_snippet(item.get(“snippet”, “”)))
occ-000260examples/search-r1/google_search_server.py:132 · 快照google_search.<comprehension>instance_candidategetunresolved_receiver_candidatelinks = [item.get(“link”, “”) for item in items if “link” in item]
occ-000262examples/search-r1/google_search_server.py:136 · 快照google_searchinstance_candidategetunresolved_receiver_candidatetitle = item.get(“title”, “”)
occ-000263examples/search-r1/google_search_server.py:137 · 快照google_searchinstance_candidategetunresolved_receiver_candidatesnippet = item.get(“snippet”, “”)
occ-000268examples/search-r1/local_search_server.py:76 · 快照local_searchinstance_candidategetunresolved_receiver_candidateretrieval_results = result.get(“result”, [[]])[0]
occ-000269examples/search-r1/local_search_server.py:86 · 快照local_searchinstance_candidategetunresolved_receiver_candidatecontent = item.get(“contents”, “”)
occ-000272examples/strands_sglang/generate_with_strands.py:85 · 快照generateinstance_candidateresetunresolved_receiver_candidatemodel.reset()
occ-000275examples/strands_sglang/subprocess_interpreter.py:141 · 快照SubprocessInterpreter.run_fileinstance_candidatereadunresolved_receiver_candidatesource = f.read()
occ-000279examples/strands_sglang/subprocess_interpreter.py:237 · 快照SubprocessInterpreter.run_fileinstance_candidatecommunicateinferred_receiver_candidate; subprocess.Popen @ L228stdout, stderr = proc.communicate(timeout=self.execution_timeout)
occ-000281examples/strands_sglang/subprocess_interpreter.py:240 · 快照SubprocessInterpreter.run_fileinstance_candidatekillinferred_receiver_candidate; subprocess.Popen @ L228proc.kill()
occ-000282examples/strands_sglang/subprocess_interpreter.py:241 · 快照SubprocessInterpreter.run_fileinstance_candidatecommunicateinferred_receiver_candidate; subprocess.Popen @ L228stdout, stderr = proc.communicate()
occ-000283examples/strands_sglang/subprocess_interpreter.py:360 · 快照SubprocessInterpreter._create_temp_fileinstance_candidatewriteunresolved_receiver_candidatef.write(code)
occ-000284examples/strands_sglang/subprocess_interpreter.py:380 · 快照SubprocessInterpreter._check_code_typeinstance_candidatejoinunresolved_receiver_candidatef”{’, ‘.join(self._CODE_EXTENSION_MAPPING.keys())}.”
occ-000292examples/strands_sglang/subprocess_interpreter.py:476 · 快照SubprocessInterpreter.execute_commandinstance_candidatecommunicateinferred_receiver_candidate; subprocess.Popen @ L467stdout, stderr = proc.communicate(timeout=self.execution_timeout)
occ-000293examples/tau-bench/generate_with_tau.py:60 · 快照res_to_sampleinstance_candidategetunresolved_receiver_candidatestatus = status_mapping.get(res.status)
occ-000299examples/tau-bench/trainable_agents.py:141 · 快照TrainableAgentMixin._initialize_environmentinstance_candidateresetunresolved_receiver_candidateenv_reset_res = env.reset(task_index=task_index)
occ-000300examples/tau-bench/trainable_agents.py:143 · 快照TrainableAgentMixin._initialize_environmentinstance_candidateresetunresolved_receiver_candidateenv_reset_res = env.reset()
occ-000304examples/tau-bench/trainable_agents.py:397 · 快照TrainableAgentMixin._build_final_resultinstance_candidatejoinunresolved_receiver_candidateres.response = “".join([msg.get(“content”, “”) for msg in messages if msg[“role”] == “assistant”])
occ-000305examples/tau-bench/trainable_agents.py:397 · 快照TrainableAgentMixin._build_final_result.<comprehension>instance_candidategetunresolved_receiver_candidateres.response = “".join([msg.get(“content”, “”) for msg in messages if msg[“role”] == “assistant”])
occ-000306slime/agent/adapters/anthropic.py:59 · 快照AnthropicAdapter._translateinstance_candidategetunresolved_receiver_candidatetranslated = _translate_messages(body.get(“messages”) or [], body.get(“system”))
occ-000307slime/agent/adapters/anthropic.py:59 · 快照AnthropicAdapter._translateinstance_candidategetunresolved_receiver_candidatetranslated = _translate_messages(body.get(“messages”) or [], body.get(“system”))
occ-000308slime/agent/adapters/anthropic.py:60 · 快照AnthropicAdapter._translateinstance_candidategetunresolved_receiver_candidatetools_schema = _tools_to_chat_tools(body.get(“tools”))
occ-000311slime/agent/adapters/anthropic.py:89 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidaterole, content = m.get(“role”), m.get(“content”)
occ-000312slime/agent/adapters/anthropic.py:89 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidaterole, content = m.get(“role”), m.get(“content”)
occ-000313slime/agent/adapters/anthropic.py:93 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidateif isinstance(b, dict) and b.get(“type”) == “tool_result”:
occ-000314slime/agent/adapters/anthropic.py:94 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatetranslated.append({“role”: “tool”, “content”: flatten_content(b.get(“content”))})
occ-000315slime/agent/adapters/anthropic.py:95 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidateelif isinstance(b, dict) and b.get(“type”) == “text”:
occ-000316slime/agent/adapters/anthropic.py:96 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatetranslated.append({“role”: “user”, “content”: b.get(“text”, “”)})
occ-000317slime/agent/adapters/anthropic.py:105 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidateif b.get(“type”) == “text”:
occ-000318slime/agent/adapters/anthropic.py:106 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatetexts.append(b.get(“text”, “”))
occ-000319slime/agent/adapters/anthropic.py:107 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidateelif b.get(“type”) == “thinking”:
occ-000320slime/agent/adapters/anthropic.py:108 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatethinkings.append(b.get(“thinking”, “”))
occ-000321slime/agent/adapters/anthropic.py:109 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidateelif b.get(“type”) == “tool_use”:
occ-000322slime/agent/adapters/anthropic.py:111 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatetcs.append(tool_call_dict(b.get(“name”, “tool”), b.get(“input”)))
occ-000323slime/agent/adapters/anthropic.py:111 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatetcs.append(tool_call_dict(b.get(“name”, “tool”), b.get(“input”)))
occ-000324slime/agent/adapters/anthropic.py:112 · 快照_translate_messagesinstance_candidatejoinunresolved_receiver_candidatemo: dict[str, Any] = {“role”: “assistant”, “content”: “".join(texts)}
occ-000325slime/agent/adapters/anthropic.py:114 · 快照_translate_messagesinstance_candidatejoinunresolved_receiver_candidatemo[“reasoning_content”] = “".join(thinkings)
occ-000326slime/agent/adapters/anthropic.py:136 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidate“description”: t.get(“description”, “”),
occ-000327slime/agent/adapters/anthropic.py:137 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidate“parameters”: t.get(“input_schema”) or t.get(“parameters”) or {“type”: “object”, “properties”: {}},
occ-000328slime/agent/adapters/anthropic.py:137 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidate“parameters”: t.get(“input_schema”) or t.get(“parameters”) or {“type”: “object”, “properties”: {}},
occ-000329slime/agent/adapters/anthropic.py:168 · 快照_build_reply_partsinstance_candidategetunresolved_receiver_candidatemanager_tcs.append(tool_call_dict(tu[“name”], tu.get(“input”)))
occ-000330slime/agent/adapters/anthropic.py:195 · 快照_request_session_idinstance_candidategetunresolved_receiver_candidatereturn sid_from_bearer(request) or (request.headers.get(“X-Api-Key”) or “”).strip() or “default”
occ-000331slime/agent/adapters/anthropic.py:203 · 快照_render_responseinstance_candidategetunresolved_receiver_candidate“model”: body.get(“model”, “slime-actor”),
occ-000335slime/agent/adapters/anthropic.py:238 · 快照_render_streaminstance_candidatewriteunresolved_receiver_candidateawait out.write(f"event: message_start\ndata: {json.dumps(ms_data, ensure_ascii=False)}\n\n”.encode())
occ-000337slime/agent/adapters/anthropic.py:256 · 快照_render_streaminstance_candidatewriteunresolved_receiver_candidateawait out.write(f"event: content_block_start\ndata: {json.dumps(cbs_data, ensure_ascii=False)}\n\n”.encode())
occ-000339slime/agent/adapters/anthropic.py:259 · 快照_render_streaminstance_candidatewriteunresolved_receiver_candidateawait out.write(f"event: content_block_delta\ndata: {json.dumps(cbd_data, ensure_ascii=False)}\n\n”.encode())
occ-000341slime/agent/adapters/anthropic.py:262 · 快照_render_streaminstance_candidatewriteunresolved_receiver_candidateawait out.write(f"event: content_block_stop\ndata: {json.dumps(cbe_data, ensure_ascii=False)}\n\n”.encode())
occ-000343slime/agent/adapters/anthropic.py:269 · 快照_render_streaminstance_candidatewriteunresolved_receiver_candidateawait out.write(f"event: message_delta\ndata: {json.dumps(md_data, ensure_ascii=False)}\n\n".encode())
occ-000345slime/agent/adapters/anthropic.py:272 · 快照_render_streaminstance_candidatewriteunresolved_receiver_candidateawait out.write(f"event: message_stop\ndata: {json.dumps(mst_data, ensure_ascii=False)}\n\n".encode())
occ-000348slime/agent/adapters/anthropic.py:280 · 快照_count_tokensinstance_candidatereadunresolved_receiver_candidateawait request.read()
occ-000349slime/agent/adapters/anthropic.py:301 · 快照_fold_mid_list_system_into_userinstance_candidategetunresolved_receiver_candidatemsgs = body_obj.get(“messages”)
occ-000350slime/agent/adapters/anthropic.py:305 · 快照_fold_mid_list_system_into_user.<comprehension>instance_candidategetunresolved_receiver_candidatesystem_idx = [i for i, m in enumerate(msgs) if isinstance(m, dict) and m.get(“role”) == “system” and i > 0]
occ-000351slime/agent/adapters/anthropic.py:310 · 快照_fold_mid_list_system_into_user._promote_to_listinstance_candidategetunresolved_receiver_candidatec = msg.get(“content”)
occ-000352slime/agent/adapters/anthropic.py:326 · 快照_fold_mid_list_system_into_userinstance_candidategetunresolved_receiver_candidatewrapped = _wrap(flatten_content(sys_msg.get(“content”)))
occ-000353slime/agent/adapters/anthropic.py:330 · 快照_fold_mid_list_system_into_userinstance_candidategetunresolved_receiver_candidateif isinstance(cand, dict) and cand.get(“role”) == “user”:
occ-000354slime/agent/adapters/anthropic.py:337 · 快照_fold_mid_list_system_into_userinstance_candidategetunresolved_receiver_candidateif isinstance(cand, dict) and cand.get(“role”) == “user”:
occ-000356slime/agent/adapters/common.py:96 · 快照flatten_contentinstance_candidategetunresolved_receiver_candidatet = b.get(“type”)
occ-000357slime/agent/adapters/common.py:98 · 快照flatten_contentinstance_candidategetunresolved_receiver_candidateparts.append(b.get(“text”, “”))
occ-000358slime/agent/adapters/common.py:100 · 快照flatten_contentinstance_candidategetunresolved_receiver_candidateparts.append(flatten_content(b.get(“content”)))
occ-000359slime/agent/adapters/common.py:104 · 快照flatten_contentinstance_candidategetunresolved_receiver_candidateparts.append(flatten_content(b.get(“content”)))
occ-000360slime/agent/adapters/common.py:106 · 快照flatten_contentinstance_candidategetunresolved_receiver_candidateparts.append(str(b.get(“text”) or “”))
occ-000361slime/agent/adapters/common.py:107 · 快照flatten_contentinstance_candidatejoinunresolved_receiver_candidatereturn “\n”.join(p for p in parts if p)
occ-000365slime/agent/adapters/common.py:228 · 快照BaseAdapter.shutdown_session.<comprehension>instance_candidatedoneunresolved_receiver_candidatetasks = [t for t in self.inflight.pop(sid, ()) if not t.done()]
occ-000369slime/agent/adapters/common.py:235 · 快照BaseAdapter.shutdown_session._draininstance_candidatecancelunresolved_receiver_candidatetask.cancel()
occ-000372slime/agent/adapters/common.py:239 · 快照BaseAdapter.shutdown_sessioninstance_candidateget_loopunresolved_receiver_candidateloop = tasks[0].get_loop()
occ-000376slime/agent/adapters/common.py:243 · 快照BaseAdapter.shutdown_sessioninstance_candidateexceptionunresolved_receiver_candidateself.logger.exception("[%s] sid=%s shutdown drain failed", self.log_prefix, sid)
occ-000381slime/agent/adapters/common.py:293 · 快照BaseAdapter._check_turn_capinstance_candidategetunresolved_receiver_candidateprior = self._sid_turn_count.get(sid, 0)
occ-000382slime/agent/adapters/common.py:316 · 快照BaseAdapter._run_debug_callbackinstance_candidateexceptionunresolved_receiver_candidateself.logger.exception(“debug_callback failed (sid=%s)”, sid)
occ-000387slime/agent/adapters/common.py:357 · 快照BaseAdapter._run_turninstance_candidategetunresolved_receiver_candidatestream = body.get(“stream”) is True or “text/event-stream” in request.headers.get(“Accept”, “”)
occ-000388slime/agent/adapters/common.py:357 · 快照BaseAdapter._run_turninstance_candidategetunresolved_receiver_candidatestream = body.get(“stream”) is True or “text/event-stream” in request.headers.get(“Accept”, “”)
occ-000392slime/agent/adapters/common.py:393 · 快照BaseAdapter._run_turninstance_candidategetunresolved_receiver_candidateself.inflight.get(sid, set()).discard(task)
occ-000393slime/agent/adapters/common.py:398 · 快照sid_from_bearerinstance_candidategetunresolved_receiver_candidateauth = request.headers.get(“Authorization”, “”)
occ-000394slime/agent/adapters/common.py:408 · 快照sid_from_bodyinstance_candidategetunresolved_receiver_candidatemetadata = body.get(“metadata”)
occ-000395slime/agent/adapters/common.py:409 · 快照sid_from_bodyinstance_candidategetunresolved_receiver_candidateif isinstance(metadata, dict) and metadata.get(“session_id”):
occ-000396slime/agent/adapters/common.py:411 · 快照sid_from_bodyinstance_candidategetunresolved_receiver_candidateif body.get(“user”):
occ-000397slime/agent/adapters/common.py:426 · 快照_sampling_paramsinstance_candidategetunresolved_receiver_candidateif body.get(key) is not None:
occ-000398slime/agent/adapters/common.py:427 · 快照_sampling_paramsinstance_candidategetunresolved_receiver_candidatesp[“max_new_tokens”] = min(int(sp.get(“max_new_tokens”, body[key])), int(body[key]))
occ-000399slime/agent/adapters/common.py:435 · 快照_sampling_paramsinstance_candidategetunresolved_receiver_candidateif body.get(key):
occ-000401slime/agent/adapters/common.py:468 · 快照call_sglang_generateinstance_candidategetunresolved_receiver_candidatesp[“max_new_tokens”] = min(int(sp.get(“max_new_tokens”, remaining_context)), remaining_context)
occ-000405slime/agent/adapters/common.py:497 · 快照call_sglang_generateinstance_candidategetunresolved_receiver_candidatemeta = data.get(“meta_info”) or {}
occ-000406slime/agent/adapters/common.py:498 · 快照call_sglang_generateinstance_candidategetunresolved_receiver_candidateoutput_token_logprobs = meta.get(“output_token_logprobs”) or []
occ-000407slime/agent/adapters/common.py:501 · 快照call_sglang_generateinstance_candidategetunresolved_receiver_candidatefinish = (meta.get(“finish_reason”) or {}).get(“type”, “stop”) or “stop”
occ-000408slime/agent/adapters/common.py:501 · 快照call_sglang_generateinstance_candidategetunresolved_receiver_candidatefinish = (meta.get(“finish_reason”) or {}).get(“type”, “stop”) or “stop”
occ-000417slime/agent/adapters/common.py:530 · 快照_abort_sglang_requestinstance_candidategetunresolved_receiver_candidateasync with session.get(f"{sglang_url}/workers") as response:
occ-000420slime/agent/adapters/common.py:543 · 快照_abort_sglang_requestinstance_candidategetunresolved_receiver_candidatefor worker in payload.get(“workers”, [])
occ-000421slime/agent/adapters/common.py:544 · 快照_abort_sglang_request.<comprehension>instance_candidategetunresolved_receiver_candidateif isinstance(worker, dict) and isinstance(worker.get(“url”), str) and worker[“url”]
occ-000425slime/agent/adapters/openai.py:54 · 快照OpenAIAdapter._translateinstance_candidategetunresolved_receiver_candidatemessages = body.get(“messages”) or []
occ-000426slime/agent/adapters/openai.py:58 · 快照OpenAIAdapter._translateinstance_candidategetunresolved_receiver_candidatetools_schema = _tools_to_chat_tools(body.get(“tools”))
occ-000429slime/agent/adapters/openai.py:120 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidaterole = msg.get(“role”)
occ-000430slime/agent/adapters/openai.py:121 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatecontent = msg.get(“content”)
occ-000431slime/agent/adapters/openai.py:135 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatereasoning = msg.get(“reasoning_content”)
occ-000432slime/agent/adapters/openai.py:138 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatetool_calls = msg.get(“tool_calls”) or []
occ-000433slime/agent/adapters/openai.py:143 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatefunction = call.get(“function”) or {}
occ-000434slime/agent/adapters/openai.py:144 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatename = function.get(“name”) or call.get(“name”) or “tool”
occ-000435slime/agent/adapters/openai.py:144 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatename = function.get(“name”) or call.get(“name”) or “tool”
occ-000436slime/agent/adapters/openai.py:145 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatearguments = function.get(“arguments”)
occ-000437slime/agent/adapters/openai.py:147 · 快照_translate_messagesinstance_candidategetunresolved_receiver_candidatearguments = call.get(“arguments”, {})
occ-000438slime/agent/adapters/openai.py:174 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidateif tool.get(“type”) and tool.get(“type”) != “function”:
occ-000439slime/agent/adapters/openai.py:174 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidateif tool.get(“type”) and tool.get(“type”) != “function”:
occ-000440slime/agent/adapters/openai.py:176 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidatefunction = tool.get(“function”) if isinstance(tool.get(“function”), dict) else None
occ-000441slime/agent/adapters/openai.py:176 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidatefunction = tool.get(“function”) if isinstance(tool.get(“function”), dict) else None
occ-000442slime/agent/adapters/openai.py:178 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidatename = function.get(“name”)
occ-000443slime/agent/adapters/openai.py:186 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidate“description”: function.get(“description”, “”),
occ-000444slime/agent/adapters/openai.py:187 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidate“parameters”: function.get(“parameters”) or {“type”: “object”, “properties”: {}},
occ-000445slime/agent/adapters/openai.py:192 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidatename = tool.get(“name”)
occ-000446slime/agent/adapters/openai.py:200 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidate“description”: tool.get(“description”, “”),
occ-000447slime/agent/adapters/openai.py:201 · 快照_tools_to_chat_toolsinstance_candidategetunresolved_receiver_candidate“parameters”: tool.get(“parameters”) or {“type”: “object”, “properties”: {}},
occ-000448slime/agent/adapters/openai.py:225 · 快照_build_reply_partsinstance_candidategetunresolved_receiver_candidatename = tu.get(“name”, “tool”)
occ-000449slime/agent/adapters/openai.py:226 · 快照_build_reply_partsinstance_candidategetunresolved_receiver_candidateargs_dict = tu.get(“input”) or {}
occ-000450slime/agent/adapters/openai.py:312 · 快照_render_responseinstance_candidategetunresolved_receiver_candidate“model”: body.get(“model”, “slime-actor”),
occ-000454slime/agent/adapters/openai.py:356 · 快照_render_stream.emitinstance_candidategetunresolved_receiver_candidate“model”: body.get(“model”, “slime-actor”),
occ-000456slime/agent/adapters/openai.py:361 · 快照_render_stream.emitinstance_candidatewriteunresolved_receiver_candidateawait out.write(f"data: {json.dumps(chunk, ensure_ascii=False)}\n\n".encode())
occ-000458slime/agent/adapters/openai.py:364 · 快照_render_streaminstance_candidategetunresolved_receiver_candidatereasoning = wire_message.get(“reasoning_content”)
occ-000460slime/agent/adapters/openai.py:367 · 快照_render_streaminstance_candidategetunresolved_receiver_candidatecontent = wire_message.get(“content”)
occ-000462slime/agent/adapters/openai.py:373 · 快照_render_streaminstance_candidategetunresolved_receiver_candidatetool_calls = wire_message.get(“tool_calls”) or []
occ-000466slime/agent/adapters/openai.py:377 · 快照_render_streaminstance_candidatewriteunresolved_receiver_candidateawait out.write(b"data: [DONE]\n\n")
occ-000474slime/agent/aiohttp_threaded.py:39 · 快照AppHandle.stopinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L38fut.result(timeout=10)
occ-000475slime/agent/aiohttp_threaded.py:42 · 快照AppHandle.stopinstance_candidatecall_soon_threadsafeunresolved_receiver_candidateself.loop.call_soon_threadsafe(self.loop.stop)
occ-000476slime/agent/aiohttp_threaded.py:43 · 快照AppHandle.stopinstance_candidatejoinunresolved_receiver_candidateself.thread.join(timeout=5)
occ-000480slime/agent/aiohttp_threaded.py:70 · 快照run_app_in_thread._runinstance_candidaterun_until_completeinferred_receiver_candidate; asyncio.AbstractEventLoop @ L66loop.run_until_complete(runner.setup())
occ-000481slime/agent/aiohttp_threaded.py:72 · 快照run_app_in_thread._runinstance_candidaterun_until_completeinferred_receiver_candidate; asyncio.AbstractEventLoop @ L66loop.run_until_complete(site.start())
occ-000482slime/agent/aiohttp_threaded.py:72 · 快照run_app_in_thread._runinstance_candidatestartunresolved_receiver_candidateloop.run_until_complete(site.start())
occ-000483slime/agent/aiohttp_threaded.py:80 · 快照run_app_in_thread._runinstance_candidatesetinferred_receiver_candidate; threading.Event @ L61started.set()
occ-000484slime/agent/aiohttp_threaded.py:81 · 快照run_app_in_thread._runinstance_candidaterun_foreverinferred_receiver_candidate; asyncio.AbstractEventLoop @ L66loop.run_forever()
occ-000485slime/agent/aiohttp_threaded.py:84 · 快照run_app_in_thread._runinstance_candidatesetinferred_receiver_candidate; threading.Event @ L61started.set()
occ-000487slime/agent/aiohttp_threaded.py:88 · 快照run_app_in_threadinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L87thread.start()
occ-000488slime/agent/aiohttp_threaded.py:89 · 快照run_app_in_threadinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L61started.wait(timeout=start_timeout_sec)
occ-000549slime/agent/sandbox.py:305 · 快照E2BSandbox.aexitinstance_candidatekillunresolved_receiver_candidateawait self._sb.kill()
occ-000555slime/agent/sandbox.py:348 · 快照E2BSandbox.write_file._do_pathinstance_candidatewriteunresolved_receiver_candidateawait self._sb.files.write(
occ-000559slime/agent/sandbox.py:363 · 快照E2BSandbox.write_file._do_bytesinstance_candidatewriteunresolved_receiver_candidateawait self._sb.files.write(
occ-000562slime/agent/sandbox.py:377 · 快照E2BSandbox.write_file.<lambda>instance_candidatewriteunresolved_receiver_candidatelambda: self._sb.files.write(sandbox_path, content, user=user),
occ-000565slime/agent/sandbox.py:384 · 快照E2BSandbox.read_file.<lambda>instance_candidatereadunresolved_receiver_candidatelambda: self._sb.files.read(sandbox_path, user=user),
occ-000571slime/backends/megatron_utils/server/megatron_server.py:79 · 快照_get_update_timeout_sinstance_candidategetunresolved_receiver_candidatereturn float(payload.get(“timeout_s”) or args.megatron_server_update_timeout_s)
occ-000572slime/backends/megatron_utils/server/megatron_server.py:181 · 快照SampleManager.cancel_request.<comprehension>instance_candidategetunresolved_receiver_candidatereq for req in self._pending_requests if req.get(“request_id”) != request_id
occ-000573slime/backends/megatron_utils/server/megatron_server.py:187 · 快照SampleManager._pop_next_requestinstance_candidategetunresolved_receiver_candidaterid = req.get(“request_id”)
occ-000574slime/backends/megatron_utils/server/megatron_server.py:204 · 快照SampleManager.get_input_datainstance_candidategetunresolved_receiver_candidatesample_n = req.get(“sample_n”, 0)
occ-000575slime/backends/megatron_utils/server/megatron_server.py:205 · 快照SampleManager.get_input_datainstance_candidategetunresolved_receiver_candidatelabel_token_ids = req.get(“label_token_ids”)
occ-000576slime/backends/megatron_utils/server/megatron_server.py:263 · 快照SampleManager.save_log_probsinstance_candidategetunresolved_receiver_candidatelog_probs = output_item.get(“log_probs”)
occ-000577slime/backends/megatron_utils/server/megatron_server.py:264 · 快照SampleManager.save_log_probsinstance_candidategetunresolved_receiver_candidatesampled_token_ids = output_item.get(“sampled_token_ids”)
occ-000578slime/backends/megatron_utils/server/megatron_server.py:265 · 快照SampleManager.save_log_probsinstance_candidategetunresolved_receiver_candidatesampled_log_probs = output_item.get(“sampled_log_probs”)
occ-000579slime/backends/megatron_utils/server/megatron_server.py:266 · 快照SampleManager.save_log_probsinstance_candidategetunresolved_receiver_candidatelabel_token_log_probs = output_item.get(“label_token_log_probs”)
occ-000580slime/backends/megatron_utils/server/megatron_server.py:287 · 快照_merge_log_probs.<lambda>instance_candidategetunresolved_receiver_candidatelogp_parts.sort(key=lambda x: x.get(“dp_rank”))
occ-000581slime/backends/megatron_utils/server/megatron_server.py:290 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidatehas_log_prob = part.get(“log_prob”) is not None
occ-000582slime/backends/megatron_utils/server/megatron_server.py:291 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidatehas_sampled = part.get(“sampled_log_probs”) is not None or part.get(“sampled_token_ids”) is not None
occ-000583slime/backends/megatron_utils/server/megatron_server.py:291 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidatehas_sampled = part.get(“sampled_log_probs”) is not None or part.get(“sampled_token_ids”) is not None
occ-000584slime/backends/megatron_utils/server/megatron_server.py:292 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidatehas_label = part.get(“label_token_log_probs”) is not None
occ-000585slime/backends/megatron_utils/server/megatron_server.py:297 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidate“log_probs”: part.get(“log_prob”),
occ-000586slime/backends/megatron_utils/server/megatron_server.py:298 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidate“sampled_log_probs”: part.get(“sampled_log_probs”),
occ-000587slime/backends/megatron_utils/server/megatron_server.py:299 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidate“sampled_token_ids”: part.get(“sampled_token_ids”),
occ-000588slime/backends/megatron_utils/server/megatron_server.py:300 · 快照_merge_log_probsinstance_candidategetunresolved_receiver_candidate“label_token_log_probs”: part.get(“label_token_log_probs”),
occ-000595slime/backends/megatron_utils/server/megatron_server.py:382 · 快照_build_generate_responseinstance_candidategetunresolved_receiver_candidate“log_probs”: _crop_sequence(result.get(“log_probs”), expected_len),
occ-000596slime/backends/megatron_utils/server/megatron_server.py:385 · 快照_build_generate_responseinstance_candidategetunresolved_receiver_candidatevalue = result.get(key)
occ-000601slime/backends/megatron_utils/server/megatron_server.py:403 · 快照_get_update_model_pathinstance_candidategetunresolved_receiver_candidatemodel_path = payload.get(“model_path”) or payload.get(“path”) or payload.get(“load”)
occ-000602slime/backends/megatron_utils/server/megatron_server.py:403 · 快照_get_update_model_pathinstance_candidategetunresolved_receiver_candidatemodel_path = payload.get(“model_path”) or payload.get(“path”) or payload.get(“load”)
occ-000603slime/backends/megatron_utils/server/megatron_server.py:403 · 快照_get_update_model_pathinstance_candidategetunresolved_receiver_candidatemodel_path = payload.get(“model_path”) or payload.get(“path”) or payload.get(“load”)
occ-000614slime/backends/megatron_utils/server/megatron_server.py:464 · 快照_build_http_app.update_from_diskinstance_candidatecreate_futureinferred_receiver_candidate; asyncio.AbstractEventLoop @ L464update_future = asyncio.get_running_loop().create_future()
occ-000617slime/backends/megatron_utils/server/megatron_server.py:472 · 快照_build_http_app.update_from_diskinstance_candidategetunresolved_receiver_candidateif result.get(“ok”) is True:
occ-000618slime/backends/megatron_utils/server/megatron_server.py:476 · 快照_build_http_app.update_from_diskinstance_candidategetunresolved_receiver_candidatereturn _json_error(result.get(“error”, “update_from_disk failed”), int(result.get(“status”, 500)))
occ-000619slime/backends/megatron_utils/server/megatron_server.py:476 · 快照_build_http_app.update_from_diskinstance_candidategetunresolved_receiver_candidatereturn _json_error(result.get(“error”, “update_from_disk failed”), int(result.get(“status”, 500)))
occ-000625slime/backends/megatron_utils/server/megatron_server.py:506 · 快照_build_http_app.update_from_diskinstance_candidateset_resultinferred_receiver_candidate; asyncio.Future @ L464update_future.set_result(result)
occ-000626slime/backends/megatron_utils/server/megatron_server.py:508 · 快照_build_http_app.update_from_diskinstance_candidateset_resultinferred_receiver_candidate; asyncio.Future @ L464update_future.set_result(error)
occ-000629slime/backends/megatron_utils/server/megatron_server.py:541 · 快照_build_http_app.generateinstance_candidategetunresolved_receiver_candidatesample_n = _parse_sample_n(payload.get(“sample_n”, 0))
occ-000630slime/backends/megatron_utils/server/megatron_server.py:543 · 快照_build_http_app.generateinstance_candidategetunresolved_receiver_candidatelabel_token_ids = _normalize_label_token_ids(payload.get(“label_token_ids”), valid_response_length)
occ-000639slime/backends/megatron_utils/server/megatron_server.py:622 · 快照_start_http_serverinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L616stats_thread.start()
occ-000640slime/backends/megatron_utils/server/megatron_server.py:667 · 快照_run_warmup_via_private_httpinstance_candidatestopunresolved_receiver_candidatewarmup_handle.stop()
occ-000644slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:124 · 快照UpdateWeightFromDiskDelta._publish_fullinstance_candidateclearunresolved_receiver_candidateself._snapshot.clear()
occ-000645slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:132 · 快照UpdateWeightFromDiskDelta._publish_fullinstance_candidatewriteunresolved_receiver_candidatewriter.write(tensors, chunk_index)
occ-000648slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:238 · 快照UpdateWeightFromDiskDelta._encode_deltainstance_candidateputinferred_receiver_candidate; queue.Queue @ L234free_q.put(torch.empty(max_bytes, dtype=torch.uint8, pin_memory=True))
occ-000649slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:247 · 快照UpdateWeightFromDiskDelta._encode_delta.diff_and_compressinstance_candidateputinferred_receiver_candidate; queue.Queue @ L234free_q.put(buf)
occ-000650slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:266 · 快照UpdateWeightFromDiskDelta._encode_delta.collectinstance_candidateresultunresolved_receiver_candidatename, new, compressed, digest, changed = fut.result()
occ-000652slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:280 · 快照UpdateWeightFromDiskDelta._encode_deltainstance_candidategetinferred_receiver_candidate; queue.Queue @ L234buf = free_q.get() # blocks when all buffers are in flight -> backpressures the gather
occ-000653slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:287 · 快照UpdateWeightFromDiskDelta._encode_deltainstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L273inflight.append(pool.submit(diff_and_compress, name, payload, nbytes, pinned))
occ-000654slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:293 · 快照UpdateWeightFromDiskDelta._encode_deltainstance_candidateshutdowninferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L273pool.shutdown()
occ-000655slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:320 · 快照_atomic_writeinstance_candidatewriteunresolved_receiver_candidatef.write(data)
occ-000657slime/backends/megatron_utils/update_weight/update_weight_from_distributed.py:237 · 快照UpdateWeightFromDistributed._ep_gather_and_convertinstance_candidatewaitunresolved_receiver_candidatehandle.wait()
occ-000658slime/backends/megatron_utils/update_weight/update_weight_from_distributed.py:239 · 快照UpdateWeightFromDistributed._ep_gather_and_convertinstance_candidateclearunresolved_receiver_candidatenamed_tensors.clear()
occ-000660slime/backends/megatron_utils/update_weight/update_weight_from_distributed.py:272 · 快照UpdateWeightFromDistributed._update_bucket_weights_from_distributedinstance_candidateclearunresolved_receiver_candidateconverted_named_tensors.clear()
occ-000661slime/backends/megatron_utils/update_weight/update_weight_from_distributed.py:362 · 快照update_weights_from_distributedinstance_candidatewaitunresolved_receiver_candidatehandle.wait()
occ-000665slime/backends/sglang_utils/deployment.py:58 · 快照_start_routerinstance_candidatestartinferred_receiver_candidate; multiprocessing.Process @ L53process.start()
occ-000667slime/backends/sglang_utils/deployment.py:60 · 快照_start_routerinstance_candidateis_aliveinferred_receiver_candidate; multiprocessing.Process @ L53assert process.is_alive()
occ-000669slime/backends/sglang_utils/server_control.py:21 · 快照unregister_workerinstance_candidategetunresolved_receiver_candidateresponse = client.get(f"{router_url}/workers", timeout=timeout)
occ-000673slime/backends/sglang_utils/server_control.py:39 · 快照get_live_router_workersinstance_candidategetunresolved_receiver_candidateresponse = await client.get(f"{router_url}/workers")
occ-000676slime/backends/sglang_utils/server_control.py:44 · 快照get_live_router_workers.checkinstance_candidategetunresolved_receiver_candidateresponse = await client.get(f"{worker[‘url’]}/health_generate")
occ-000680slime/backends/sglang_utils/server_control.py:72 · 快照num_requests_from_loadinstance_candidategetunresolved_receiver_candidatevalue = load.get(key)
occ-000681slime/backends/sglang_utils/server_control.py:77 · 快照num_requests_from_loadinstance_candidategetunresolved_receiver_candidaterunning = load.get(“num_running_reqs”, load.get(“total_running_reqs”))
occ-000682slime/backends/sglang_utils/server_control.py:77 · 快照num_requests_from_loadinstance_candidategetunresolved_receiver_candidaterunning = load.get(“num_running_reqs”, load.get(“total_running_reqs”))
occ-000683slime/backends/sglang_utils/server_control.py:78 · 快照num_requests_from_loadinstance_candidategetunresolved_receiver_candidatewaiting = load.get(“num_waiting_reqs”, load.get(“total_waiting_reqs”))
occ-000684slime/backends/sglang_utils/server_control.py:78 · 快照num_requests_from_loadinstance_candidategetunresolved_receiver_candidatewaiting = load.get(“num_waiting_reqs”, load.get(“total_waiting_reqs”))
occ-000685slime/backends/sglang_utils/server_control.py:110 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidateloads = load.get(“loads”, [load])
occ-000686slime/backends/sglang_utils/server_control.py:118 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidatedp_rank = rank_load.get(“dp_rank”)
occ-000687slime/backends/sglang_utils/server_control.py:120 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidateinflight = rank_load.get(“inflight”)
occ-000688slime/backends/sglang_utils/server_control.py:125 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidatereqs = queue.get(“reqs”) if isinstance(queue.get(“reqs”), list) else []
occ-000689slime/backends/sglang_utils/server_control.py:125 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidatereqs = queue.get(“reqs”) if isinstance(queue.get(“reqs”), list) else []
occ-000690slime/backends/sglang_utils/server_control.py:126 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidatecount = queue.get(“num_reqs”, len(reqs))
occ-000691slime/backends/sglang_utils/server_control.py:130 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidate{“dp_rank”: dp_rank, “queue”: queue.get(“name”, “unknown”), “num_reqs”: count, “reqs”: reqs}
occ-000692slime/backends/sglang_utils/server_control.py:137 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidatesection = rank_load.get(section_name)
occ-000693slime/backends/sglang_utils/server_control.py:144 · 快照non_idle_request_detailsinstance_candidategetunresolved_receiver_candidatevalue = rank_load.get(key)
occ-000709slime/backends/sglang_utils/server_control.py:251 · 快照abort_servers_until_idleinstance_candidatejoinunresolved_receiver_candidatedetail = “; “.join(f”{url}: {error}” for url, error in failures)
occ-000717slime/backends/sglang_utils/sglang_engine.py:52 · 快照launch_server_processinstance_candidatestartinferred_receiver_candidate; multiprocessing.Process @ L51p.start()
occ-000718slime/backends/sglang_utils/sglang_engine.py:60 · 快照launch_server_process.<lambda>instance_candidateis_aliveinferred_receiver_candidate; multiprocessing.Process @ L51is_process_alive=lambda: p.is_alive(),
occ-000720slime/backends/sglang_utils/sglang_engine.py:86 · 快照_wait_server_healthyinstance_candidategetunresolved_receiver_candidateresponse = session.get(f"{base_url}/health_generate", headers=headers, timeout=5)
occ-000722slime/backends/sglang_utils/sglang_engine.py:173 · 快照SGLangEngine._init_external._sanity_check_server_argsinstance_candidategetunresolved_receiver_candidateexpect_value = expect_server_args.get(name)
occ-000723slime/backends/sglang_utils/sglang_engine.py:174 · 快照SGLangEngine._init_external._sanity_check_server_argsinstance_candidategetunresolved_receiver_candidateactual_value = actual_server_args.get(name)
occ-000724slime/backends/sglang_utils/sglang_engine.py:199 · 快照SGLangEngine._register_to_routerinstance_candidategetunresolved_receiver_candidatebootstrap_port = server_args_dict.get(“disaggregation_bootstrap_port”)
occ-000727slime/backends/sglang_utils/sglang_engine.py:529 · 快照SGLangEngine.simulate_crashinstance_candidateshutdownunresolved_receiver_candidateself.shutdown()
occ-000728slime/backends/sglang_utils/sglang_engine.py:547 · 快照_compute_server_argsinstance_candidategetunresolved_receiver_candidatepp_size = int(normalized_overrides.get(“pp_size”, args.sglang_pp_size))
occ-000729slime/backends/sglang_utils/sglang_engine.py:548 · 快照_compute_server_argsinstance_candidategetunresolved_receiver_candidatetp_size = int(normalized_overrides.get(“tp_size”, _gpus_per_engine // pp_size))
occ-000730slime/backends/sglang_utils/sglang_engine.py:633 · 快照_compute_server_argsinstance_candidategetunresolved_receiver_candidateand kwargs.get(“enable_memory_saver”)
occ-000731slime/backends/sglang_utils/sglang_engine.py:634 · 快照_compute_server_argsinstance_candidategetunresolved_receiver_candidateand kwargs.get(“cuda_graph_backend_prefill”) is None
occ-000732slime/data/archive.py:26 · 快照RolloutArchive.initinstance_candidategetunresolved_receiver_candidateif self.index.get(“format”) != “slime.straw-debug” or self.index.get(“version”) != 1:
occ-000733slime/data/archive.py:26 · 快照RolloutArchive.initinstance_candidategetunresolved_receiver_candidateif self.index.get(“format”) != “slime.straw-debug” or self.index.get(“version”) != 1:
occ-000736slime/data/archive.py:133 · 快照RolloutArchive.saveinstance_candidatecloseunresolved_receiver_candidatestore.close()
occ-000737slime/data/archive.py:146 · 快照RolloutArchive.check_metadatainstance_candidategetunresolved_receiver_candidateif index.get(“format”) != “slime.straw-debug” or index.get(“version”) != 1:
occ-000738slime/data/archive.py:146 · 快照RolloutArchive.check_metadatainstance_candidategetunresolved_receiver_candidateif index.get(“format”) != “slime.straw-debug” or index.get(“version”) != 1:
occ-000739slime/data/archive.py:148 · 快照RolloutArchive.check_metadatainstance_candidategetunresolved_receiver_candidatemetadata = index.get(“sample_metadata”)
occ-000740slime/data/archive.py:154 · 快照RolloutArchive.check_metadatainstance_candidategetunresolved_receiver_candidateif metadata.get(“version”) != 1:
occ-000741slime/data/archive.py:184 · 快照RolloutArchive.load_samplesinstance_candidategetunresolved_receiver_candidatechunk = entry.get(“chunk”, “raw”)
occ-000742slime/data/archive.py:222 · 快照RolloutArchive.releaseinstance_candidatereleaseunresolved_receiver_candidateself.store.release(self.index[“storage_owner”])
occ-000743slime/data/archive.py:225 · 快照RolloutArchive.closeinstance_candidatecloseunresolved_receiver_candidateself.store.close()
occ-000744slime/data/archive.py:231 · 快照RolloutArchive.exitinstance_candidatecloseunresolved_receiver_candidateself.close()
occ-000753slime/data/queue_data_source.py:84 · 快照RolloutQueueController.initinstance_candidategetunresolved_receiver_candidateif parent := branch.get(“parent”):
occ-000758slime/data/queue_data_source.py:185 · 快照RolloutQueueController._start_gcinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L184self._gc_thread.start()
occ-000759slime/data/queue_data_source.py:200 · 快照RolloutQueueController._gc_loopinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L154while not self._gc_stop.wait(60):
occ-000760slime/data/queue_data_source.py:205 · 快照RolloutQueueController._gc_loopinstance_candidatesetinferred_receiver_candidate; threading.Event @ L154self._gc_stop.set()
occ-000761slime/data/queue_data_source.py:206 · 快照RolloutQueueController._gc_loopinstance_candidateexceptionunresolved_receiver_candidatelogger.exception(“straw online GC failed; retained storage must be inspected”)
occ-000762slime/data/queue_data_source.py:263 · 快照RolloutQueueController.configuration.<lambda>instance_candidatereadunresolved_receiver_candidatefor chunk in iter(lambda: stream.read(4 * 1024 * 1024), b""):
occ-000763slime/data/queue_data_source.py:292 · 快照RolloutQueueController.pending_snapshotinstance_candidategetunresolved_receiver_candidateinflight = self.queue.metrics()[“tasks”].get(“leased”, 0) > 0
occ-000764slime/data/queue_data_source.py:324 · 快照RolloutQueueController.fork_sourceinstance_candidategetunresolved_receiver_candidateif “producer_cursor” not in pending or pending.get(“inflight”, True):
occ-000765slime/data/queue_data_source.py:356 · 快照RolloutQueueController.fork_sourceinstance_candidateresultunresolved_receiver_candidatereceipt = self.result(Lease(**status[“lease”]))
occ-000766slime/data/queue_data_source.py:358 · 快照RolloutQueueController.fork_sourceinstance_candidateacquireunresolved_receiver_candidatepage = self.queue.acquire(“fork-import”, 1, task_ids=[task_id])
occ-000767slime/data/queue_data_source.py:403 · 快照RolloutQueueController.pending_count.<comprehension>instance_candidategetunresolved_receiver_candidatereturn sum(spec.metadata.get(“returned”, False) for spec in self.queue.pending_tasks(task_prefix=“prompt:”))
occ-000768slime/data/queue_data_source.py:438 · 快照RolloutQueueController.restore_pending.<comprehension>instance_candidategetunresolved_receiver_candidatekey: saved.get(key, default)
occ-000769slime/data/queue_data_source.py:447 · 快照RolloutQueueController.restore_pendinginstance_candidatereleaseunresolved_receiver_candidateself.release([Lease(**status[“lease”])])
occ-000770slime/data/queue_data_source.py:448 · 快照RolloutQueueController.restore_pendinginstance_candidateacquireunresolved_receiver_candidatepage = self.queue.acquire(“checkpoint-restore”, 1, task_ids=[saved[“task_id”]])
occ-000771slime/data/queue_data_source.py:459 · 快照RolloutQueueController.restore_pendinginstance_candidateresultunresolved_receiver_candidatereceipt = self.result(Lease(**status[“lease”])) if status and status[“state”] == “completed” else None
occ-000772slime/data/queue_data_source.py:463 · 快照RolloutQueueController.restore_pendinginstance_candidategetunresolved_receiver_candidateset(metadata.get(“source_positions”, [])) | {receipt.position}
occ-000773slime/data/queue_data_source.py:486 · 快照RolloutQueueController.reader_metadatainstance_candidategetunresolved_receiver_candidatereturn self.codec.load(RecordSetRef.from_dict(state[“state_ref”])).get(“metadata”, {}) if state else {}
occ-000774slime/data/queue_data_source.py:501 · 快照RolloutQueueController.takeinstance_candidateacquireunresolved_receiver_candidatepage = self.queue.acquire(reader_id, count, task_prefix=“prompt:”)
occ-000775slime/data/queue_data_source.py:506 · 快照RolloutQueueController.takeinstance_candidateacquireunresolved_receiver_candidatepage = self.queue.acquire(reader_id, count, task_prefix=“prompt:”)
occ-000776slime/data/queue_data_source.py:558 · 快照RolloutQueueController.takeinstance_candidateacquireunresolved_receiver_candidatereturn self.queue.acquire(reader_id, requested, task_prefix=“prompt:”)
occ-000777slime/data/queue_data_source.py:564 · 快照RolloutQueueController.completeinstance_candidateresultunresolved_receiver_candidateif lease.worker_id in self._retired_readers and self.result(lease) is None:
occ-000778slime/data/queue_data_source.py:580 · 快照RolloutQueueController.rejectinstance_candidategetunresolved_receiver_candidatepositions = self.queue.task_status(lease.task_id)[“spec”][“metadata”].get(“source_positions”, [])
occ-000779slime/data/queue_data_source.py:596 · 快照RolloutQueueController.results.<comprehension>instance_candidateresultunresolved_receiver_candidatereturn [self.result(lease) if lease else None for lease in leases]
occ-000780slime/data/queue_data_source.py:621 · 快照RolloutQueueController.recover_reader_results.<comprehension>instance_candidategetunresolved_receiver_candidatefor position in task[“spec”][“metadata”].get(“source_positions”, [])
occ-000781slime/data/queue_data_source.py:657 · 快照RolloutQueueController.recover_pending_rolloutinstance_candidategetunresolved_receiver_candidateif state.get(“conversion_started”) or state[“processed_cursor”] or state[“processed_positions”]:
occ-000782slime/data/queue_data_source.py:665 · 快照RolloutQueueController.recover_pending_rollout.<comprehension>instance_candidategetunresolved_receiver_candidatefor position in task[“spec”][“metadata”].get(“source_positions”, [])
occ-000783slime/data/queue_data_source.py:685 · 快照RolloutQueueController.begin_collectioninstance_candidateacquireunresolved_receiver_candidatepage = self.queue.acquire(“manager”, 1, task_ids=[task_id], control=True)
occ-000784slime/data/queue_data_source.py:702 · 快照RolloutQueueController.batchinstance_candidateresultunresolved_receiver_candidatereceipt = self.result(Lease(**task[“lease”])) if task[“state”] == “completed” else None
occ-000785slime/data/queue_data_source.py:706 · 快照RolloutQueueController.batchinstance_candidategetunresolved_receiver_candidate“lease”: task.get(“lease”),
occ-000786slime/data/queue_data_source.py:723 · 快照RolloutQueueController.plan_batchinstance_candidateacquireunresolved_receiver_candidateself.queue.acquire(“manager”, 1, task_ids=[batch_id], control=True)
occ-000787slime/data/queue_data_source.py:725 · 快照RolloutQueueController.plan_batchinstance_candidategetunresolved_receiver_candidateif not state.get(“conversion_started”):
occ-000788slime/data/queue_data_source.py:756 · 快照RolloutQueueController._advanceinstance_candidategetunresolved_receiver_candidatepositions.update(task[“spec”][“metadata”].get(“source_positions”, []))
occ-000789slime/data/queue_data_source.py:821 · 快照RolloutQueueController.ready_batchinstance_candidateacquireunresolved_receiver_candidatepage = self.queue.acquire(“manager”, 1, task_ids=[batch_id], control=True)
occ-000790slime/data/queue_data_source.py:838 · 快照RolloutQueueController.finish_batchinstance_candidateresultunresolved_receiver_candidatereceipt = self.result(Lease(**task[“lease”]))
occ-000791slime/data/queue_data_source.py:851 · 快照RolloutQueueController.record_dispositionsinstance_candidategetunresolved_receiver_candidateif not decision.get(“reason”) or any(
occ-000792slime/data/queue_data_source.py:903 · 快照RolloutQueueController.restore_training_state.visitinstance_candidateresultunresolved_receiver_candidatereceipt = self.result(Lease(**lease))
occ-000793slime/data/queue_data_source.py:907 · 快照RolloutQueueController.restore_training_state.visitinstance_candidateresultunresolved_receiver_candidatereceipt = self.result(Lease(**task[“lease”]))
occ-000794slime/data/queue_data_source.py:911 · 快照RolloutQueueController.restore_training_state.visitinstance_candidategetunresolved_receiver_candidateretained.update(value.get(“source_positions”, []))
occ-000795slime/data/queue_data_source.py:970 · 快照RolloutQueueController.closeinstance_candidatesetinferred_receiver_candidate; threading.Event @ L154self._gc_stop.set()
occ-000796slime/data/queue_data_source.py:972 · 快照RolloutQueueController.closeinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L184self._gc_thread.join()
occ-000797slime/data/queue_data_source.py:974 · 快照RolloutQueueController.closeinstance_candidatecloseunresolved_receiver_candidateself._queue.close()
occ-000798slime/data/queue_data_source.py:983 · 快照RolloutQueueController.closeinstance_candidatecloseunresolved_receiver_candidateself._checkpoint_lock.close()
occ-000803slime/data/queue_data_source.py:1045 · 快照QueueReader.initinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L1044self._heartbeats.start()
occ-000804slime/data/queue_data_source.py:1049 · 快照QueueReader._heartbeat_loopinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L1036while not self._stop.wait(interval):
occ-000805slime/data/queue_data_source.py:1058 · 快照QueueReader._heartbeat_loopinstance_candidategetunresolved_receiver_candidateif self._leases.get(lease.task_id) != lease:
occ-000807slime/data/queue_data_source.py:1107 · 快照QueueReader.get_samplesinstance_candidategetunresolved_receiver_candidatesample._queue_source_positions = assignment.task.metadata.get(“source_positions”, [])
occ-000811slime/data/queue_data_source.py:1115 · 快照QueueReader.get_samples_asyncinstance_candidaterun_in_executorinferred_receiver_candidate; asyncio.AbstractEventLoop @ L1115return await asyncio.get_running_loop().run_in_executor(self._reader, self.get_samples, num_samples)
occ-000812slime/data/queue_data_source.py:1146 · 快照QueueReader.add_samplesinstance_candidategetunresolved_receiver_candidateif self._leases.get(lease.task_id) == lease:
occ-000813slime/data/queue_data_source.py:1210 · 快照QueueReader.add_samplesinstance_candidategetunresolved_receiver_candidateif lease and self._leases.get(lease.task_id) == lease:
occ-000814slime/data/queue_data_source.py:1284 · 快照QueueReader.closeinstance_candidateshutdowninferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L1035self._reader.shutdown(wait=True)
occ-000815slime/data/queue_data_source.py:1288 · 快照QueueReader.closeinstance_candidatesetinferred_receiver_candidate; threading.Event @ L1036self._stop.set()
occ-000816slime/data/queue_data_source.py:1289 · 快照QueueReader.closeinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L1044self._heartbeats.join(timeout=5)
occ-000817slime/data/queue_data_source.py:1417 · 快照QueueDataSource.loadinstance_candidategetunresolved_receiver_candidateif state[“configuration”].get(“dataset”) != self.data_config.get(“dataset”):
occ-000818slime/data/queue_data_source.py:1417 · 快照QueueDataSource.loadinstance_candidategetunresolved_receiver_candidateif state[“configuration”].get(“dataset”) != self.data_config.get(“dataset”):
occ-000819slime/data/queue_data_source.py:1424 · 快照QueueDataSource.loadinstance_candidategetunresolved_receiver_candidateif state[“configuration”].get(“queue_id”, self.data_config[“queue_id”]) != self.data_config[“queue_id”]:
occ-000820slime/data/queue_data_source.py:1438 · 快照QueueDataSource.closeinstance_candidatecloseunresolved_receiver_candidateconsumer.close()
occ-000821slime/data/queue_data_source.py:1439 · 快照QueueDataSource.closeinstance_candidatecloseunresolved_receiver_candidatesuper().close()
occ-000826slime/data/transport.py:49 · 快照resolve_rollout_data_dirinstance_candidatejoinunresolved_receiver_candidatepattern = “".join(
occ-000827slime/data/transport.py:59 · 快照resolve_rollout_data_dirinstance_candidategetunresolved_receiver_candidateif index.get(“format”) != “slime.straw-debug” or index.get(“version”) != 1:
occ-000828slime/data/transport.py:59 · 快照resolve_rollout_data_dirinstance_candidategetunresolved_receiver_candidateif index.get(“format”) != “slime.straw-debug” or index.get(“version”) != 1:
occ-000844slime/data/transport.py:383 · 快照run_rollout_ioinstance_candidatedoneinferred_receiver_candidate; asyncio.Task @ L377while not pending.done():
occ-000848slime/data/transport.py:388 · 快照run_rollout_ioinstance_candidateresultinferred_receiver_candidate; asyncio.Task @ L377pending.result()
occ-000854slime/data/transport.py:483 · 快照check_rollout_storage.<comprehension>instance_candidategetunresolved_receiver_candidateif node[“Alive”] and (node[“Resources”].get(“CPU”, 0) or node[“Resources”].get(“GPU”, 0))
occ-000855slime/data/transport.py:483 · 快照check_rollout_storage.<comprehension>instance_candidategetunresolved_receiver_candidateif node[“Alive”] and (node[“Resources”].get(“CPU”, 0) or node[“Resources”].get(“GPU”, 0))
occ-000862slime/observability/trace_utils.py:144 · 快照build_sglang_meta_trace_attrsinstance_candidategetunresolved_receiver_candidatefinish_reason = meta.get(“finish_reason”)
occ-000863slime/observability/trace_utils.py:145 · 快照build_sglang_meta_trace_attrsinstance_candidategetunresolved_receiver_candidateif isinstance(finish_reason, dict) and finish_reason.get(“type”) is not None:
occ-000864slime/observability/trace_utils.py:150 · 快照build_sglang_meta_trace_attrsinstance_candidategetunresolved_receiver_candidateif meta.get(“id”) is not None:
occ-000865slime/observability/trace_utils.py:234 · 快照_ensure_trace_carrierinstance_candidategetunresolved_receiver_candidatecarrier[“attempt”] = int(carrier.get(“attempt”, attempt))
occ-000866slime/observability/trace_utils.py:248 · 快照bind_traceinstance_candidategetunresolved_receiver_candidatesample_id=sample.trace.get(“sample_id”),
occ-000867slime/observability/trace_utils.py:249 · 快照bind_traceinstance_candidategetunresolved_receiver_candidategroup_id=sample.trace.get(“group_id”),
occ-000868slime/observability/trace_utils.py:250 · 快照bind_traceinstance_candidategetunresolved_receiver_candidateattempt=int(sample.trace.get(“attempt”, 0)),
occ-000869slime/observability/trace_utils.py:277 · 快照bind_trace_carrierinstance_candidategetunresolved_receiver_candidatesample_id=trace.get(“sample_id”),
occ-000870slime/observability/trace_utils.py:278 · 快照bind_trace_carrierinstance_candidategetunresolved_receiver_candidategroup_id=trace.get(“group_id”),
occ-000871slime/observability/trace_utils.py:279 · 快照bind_trace_carrierinstance_candidategetunresolved_receiver_candidateattempt=int(trace.get(“attempt”, 0)),
occ-000872slime/observability/trace_utils.py:315 · 快照import_traceinstance_candidategetunresolved_receiver_candidatetrace_id=payload.get(“trace_id”),
occ-000873slime/observability/trace_utils.py:316 · 快照import_traceinstance_candidategetunresolved_receiver_candidatesample_id=payload.get(“sample_id”),
occ-000874slime/observability/trace_utils.py:317 · 快照import_traceinstance_candidategetunresolved_receiver_candidategroup_id=payload.get(“group_id”),
occ-000875slime/observability/trace_utils.py:318 · 快照import_traceinstance_candidategetunresolved_receiver_candidateattempt=int(payload.get(“attempt”, 0)),
occ-000876slime/observability/trace_utils.py:319 · 快照import_traceinstance_candidategetunresolved_receiver_candidateparent_span_id=payload.get(“parent_span_id”),
occ-000877slime/observability/trace_utils.py:363 · 快照trace_spaninstance_candidategetinferred_receiver_candidate; contextvars.ContextVar @ L47stack_before = _TRACE_STACK.get()
occ-000878slime/observability/trace_utils.py:364 · 快照trace_spaninstance_candidategetinferred_receiver_candidate; contextvars.ContextVar @ L51handle_stack_before = _TRACE_HANDLE_STACK.get()
occ-000879slime/observability/trace_utils.py:383 · 快照trace_spaninstance_candidatesetinferred_receiver_candidate; contextvars.ContextVar @ L47token = _TRACE_STACK.set(stack_before + tuple(new_entries))
occ-000880slime/observability/trace_utils.py:384 · 快照trace_spaninstance_candidatesetinferred_receiver_candidate; contextvars.ContextVar @ L51handle_token = _TRACE_HANDLE_STACK.set(handle_stack_before + (tuple(handles),))
occ-000881slime/observability/trace_utils.py:419 · 快照trace_spaninstance_candidateresetinferred_receiver_candidate; contextvars.ContextVar @ L47_TRACE_STACK.reset(token)
occ-000882slime/observability/trace_utils.py:423 · 快照trace_spaninstance_candidateresetinferred_receiver_candidate; contextvars.ContextVar @ L51_TRACE_HANDLE_STACK.reset(handle_token)
occ-000883slime/observability/trace_utils.py:436 · 快照trace_next_attemptinstance_candidategetunresolved_receiver_candidatenext_attempt = int(handle.carrier.get(“attempt”, 0)) + 1
occ-000888slime/observability/trace_utils.py:535 · 快照_append_trace_childreninstance_candidategetunresolved_receiver_candidatechild_type = child.get(“type”)
occ-000889slime/observability/trace_utils.py:536 · 快照_append_trace_childreninstance_candidategetunresolved_receiver_candidatechild_name = child.get(“name”)
occ-000890slime/observability/trace_utils.py:541 · 快照_append_trace_childreninstance_candidategetunresolved_receiver_candidateattrs = child.get(“attrs”) if isinstance(child.get(“attrs”), dict) else None
occ-000891slime/observability/trace_utils.py:541 · 快照_append_trace_childreninstance_candidategetunresolved_receiver_candidateattrs = child.get(“attrs”) if isinstance(child.get(“attrs”), dict) else None
occ-000892slime/observability/trace_utils.py:573 · 快照_append_trace_childreninstance_candidategetunresolved_receiver_candidatechild.get(“children”),
occ-000893slime/observability/trace_utils.py:604 · 快照_append_eventinstance_candidategetunresolved_receiver_candidate“attempt”: int(handle.carrier.get(“attempt”, handle.attempt)),
occ-000894slime/observability/trace_utils.py:635 · 快照_get_current_parent_span_idinstance_candidategetinferred_receiver_candidate; contextvars.ContextVar @ L47stack = _TRACE_STACK.get() if stack is None else stack
occ-000895slime/observability/trace_utils.py:664 · 快照_resolve_trace_function_targetinstance_candidategetunresolved_receiver_candidateresolved = _normalize_trace_target(bound.arguments.get(target))
occ-000896slime/observability/trace_utils.py:755 · 快照_get_current_trace_targetinstance_candidategetinferred_receiver_candidate; contextvars.ContextVar @ L51handle_stack = _TRACE_HANDLE_STACK.get()
occ-000898slime/ray/actor_group.py:189 · 快照RayTrainGroup.update_weightsinstance_candidatereleaseunresolved_receiver_candidateself.release()
occ-000900slime/ray/actor_group.py:291 · 快照RayTrainGroup._reload_rollout_weights_from_diskinstance_candidatejoinunresolved_receiver_candidatef"Expected: {weight_version}; " + “, “.join(mismatches)
occ-000904slime/ray/serving.py:76 · 快照ServingCluster.initinstance_candidateexceptionunresolved_receiver_candidatelogging.getLogger(name).exception(“Failed to dispose partial serving deployment”)
occ-000905slime/ray/serving.py:115 · 快照ServingCluster.validate_attachmentinstance_candidatejoinunresolved_receiver_candidateraise ValueError(“Retained serving requires unchanged rollout/model configuration: " + “, “.join(changed))
occ-000906slime/ray/serving.py:168 · 快照ServingCluster.attach_traininginstance_candidatestopunresolved_receiver_candidatemonitor.stop()
occ-000907slime/ray/serving.py:173 · 快照ServingCluster.attach_traininginstance_candidatestartunresolved_receiver_candidatemonitor.start()
occ-000908slime/ray/serving.py:318 · 快照ServingCluster.disposeinstance_candidateis_aliveunresolved_receiver_candidateif router.is_alive():
occ-000909slime/ray/serving.py:321 · 快照ServingCluster.disposeinstance_candidateis_aliveunresolved_receiver_candidateif router.is_alive():
occ-000913slime/rollout/fully_async_distributed.py:91 · 快照RolloutScheduler._retire_workerinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000914slime/rollout/fully_async_distributed.py:108 · 快照RolloutScheduler._runinstance_candidategetunresolved_receiver_candidateif not self.capacities[i] or i in configuring or configurations.get(i) == desired:
occ-000915slime/rollout/fully_async_distributed.py:126 · 快照RolloutScheduler._runinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000916slime/rollout/fully_async_distributed.py:127 · 快照RolloutScheduler._runinstance_candidatewaitinferred_receiver_candidate; threading.Condition @ L60self.condition.wait(timeout=0.05)
occ-000917slime/rollout/fully_async_distributed.py:147 · 快照RolloutScheduler._runinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000918slime/rollout/fully_async_distributed.py:151 · 快照RolloutScheduler._runinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000919slime/rollout/fully_async_distributed.py:156 · 快照RolloutScheduler._runinstance_candidateclearunresolved_receiver_candidateself.controls.clear()
occ-000920slime/rollout/fully_async_distributed.py:157 · 快照RolloutScheduler._runinstance_candidateclearunresolved_receiver_candidateself.pending.clear()
occ-000921slime/rollout/fully_async_distributed.py:158 · 快照RolloutScheduler._runinstance_candidateclearunresolved_receiver_candidateself.running_workers.clear()
occ-000922slime/rollout/fully_async_distributed.py:159 · 快照RolloutScheduler._runinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000923slime/rollout/fully_async_distributed.py:171 · 快照RolloutScheduler.generateinstance_candidateclearunresolved_receiver_candidateself.collecting.clear()
occ-000925slime/rollout/fully_async_distributed.py:178 · 快照RolloutScheduler.generateinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L177self.thread.start()
occ-000926slime/rollout/fully_async_distributed.py:179 · 快照RolloutScheduler.generateinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000927slime/rollout/fully_async_distributed.py:184 · 快照RolloutScheduler.generateinstance_candidatewaitinferred_receiver_candidate; threading.Condition @ L60self.condition.wait()
occ-000928slime/rollout/fully_async_distributed.py:198 · 快照RolloutScheduler.generateinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000929slime/rollout/fully_async_distributed.py:211 · 快照RolloutScheduler.pauseinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000930slime/rollout/fully_async_distributed.py:214 · 快照RolloutScheduler.pause.<comprehension>instance_candidategetunresolved_receiver_candidateself.configurations.get(worker) != (True, self.rollout_id) for worker in self.running_workers
occ-000931slime/rollout/fully_async_distributed.py:220 · 快照RolloutScheduler.pauseinstance_candidatewaitinferred_receiver_candidate; threading.Condition @ L60self.condition.wait()
occ-000932slime/rollout/fully_async_distributed.py:228 · 快照RolloutScheduler.resumeinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000933slime/rollout/fully_async_distributed.py:248 · 快照RolloutScheduler.closeinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L60self.condition.notify_all()
occ-000934slime/rollout/fully_async_distributed.py:250 · 快照RolloutScheduler.closeinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L177self.thread.join()
occ-000940slime/rollout/fully_async_distributed.py:286 · 快照_GenerationActor._startinstance_candidatedoneunresolved_receiver_candidateif self.producer is None or self.producer.done():
occ-000941slime/rollout/fully_async_distributed.py:288 · 快照_GenerationActor._startinstance_candidateresultunresolved_receiver_candidateself.producer.result()
occ-000955slime/rollout/fully_async_distributed.py:306 · 快照_GenerationActor._nextinstance_candidategetinferred_receiver_candidate; asyncio.Queue @ L291take = asyncio.create_task(self.outputs.get())
occ-000959slime/rollout/fully_async_distributed.py:309 · 快照_GenerationActor._nextinstance_candidatedoneinferred_receiver_candidate; asyncio.Task @ L306if take.done():
occ-000960slime/rollout/fully_async_distributed.py:310 · 快照_GenerationActor._nextinstance_candidateresultinferred_receiver_candidate; asyncio.Task @ L306return take.result()
occ-000961slime/rollout/fully_async_distributed.py:311 · 快照_GenerationActor._nextinstance_candidateresultinferred_receiver_candidate; asyncio.Task @ L292self.producer.result() # Propagate custom generation errors.
occ-000962slime/rollout/fully_async_distributed.py:312 · 快照_GenerationActor._nextinstance_candidateemptyinferred_receiver_candidate; asyncio.Queue @ L291if not self.outputs.empty():
occ-000964slime/rollout/fully_async_distributed.py:316 · 快照_GenerationActor._nextinstance_candidatecancelinferred_receiver_candidate; asyncio.Task @ L306take.cancel()
occ-000971slime/rollout/fully_async_distributed.py:325 · 快照_GenerationActor._produce.generate_slotinstance_candidateputinferred_receiver_candidate; asyncio.Queue @ L291await self.outputs.put(output)
occ-000978slime/rollout/fully_async_distributed.py:341 · 快照_GenerationActor._produceinstance_candidatecancelunresolved_receiver_candidatetask.cancel()
occ-000994slime/rollout/fully_async_distributed.py:401 · 快照_GenerationActor._rebufferinstance_candidatecreate_futureinferred_receiver_candidate; asyncio.AbstractEventLoop @ L401future = asyncio.get_running_loop().create_future()
occ-001003slime/rollout/fully_async_distributed.py:416 · 快照_GenerationActor._flush_rebuffersinstance_candidateset_exceptionunresolved_receiver_candidatefuture.set_exception(error)
occ-001004slime/rollout/fully_async_distributed.py:417 · 快照_GenerationActor._flush_rebuffersinstance_candidateclearunresolved_receiver_candidateself._pending_rebuffers.clear()
occ-001005slime/rollout/fully_async_distributed.py:420 · 快照_GenerationActor._flush_rebuffersinstance_candidateset_resultunresolved_receiver_candidatefuture.set_result(None)
occ-001006slime/rollout/fully_async_distributed.py:429 · 快照_GenerationActor.load_state_dictinstance_candidategetunresolved_receiver_candidateif isinstance(state, dict) and state.get(“worker_state”) == 1:
occ-001012slime/rollout/fully_async_distributed.py:441 · 快照_GenerationActor._closeinstance_candidatecancelinferred_receiver_candidate; asyncio.Task @ L292self.producer.cancel()
occ-001018slime/rollout/fully_async_distributed.py:447 · 快照_GenerationActor._closeinstance_candidateshutdown_default_executorinferred_receiver_candidate; asyncio.AbstractEventLoop @ L447await asyncio.get_running_loop().shutdown_default_executor()
occ-001019slime/rollout/fully_async_distributed.py:448 · 快照_GenerationActor._closeinstance_candidatecloseunresolved_receiver_candidateself.data_source.close()
occ-001020slime/rollout/fully_async_distributed.py:502 · 快照DistributedRollout.init.<comprehension>instance_candidategetunresolved_receiver_candidate(node for node in ray.nodes() if node[“Alive”] and node[“Resources”].get(“CPU”, 0) >= 1),
occ-001021slime/rollout/fully_async_distributed.py:576 · 快照DistributedRollout.closeinstance_candidatecloseunresolved_receiver_candidatesuper().close()
occ-001025slime/rollout/fully_async_rollout.py:59 · 快照_get_workerinstance_candidategetunresolved_receiver_candidateworker = data_buffer.consumers.get(“fully_async”)
occ-001026slime/rollout/fully_async_rollout.py:74 · 快照_get_workerinstance_candidatestartunresolved_receiver_candidateworker.start()
occ-001031slime/rollout/fully_async_rollout.py:105 · 快照AsyncRolloutWorker.startinstance_candidateis_aliveunresolved_receiver_candidateif self.worker_thread is None or not self.worker_thread.is_alive():
occ-001033slime/rollout/fully_async_rollout.py:107 · 快照AsyncRolloutWorker.startinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L106self.worker_thread.start()
occ-001034slime/rollout/fully_async_rollout.py:114 · 快照AsyncRolloutWorker.pauseinstance_candidatewaitinferred_receiver_candidate; threading.Condition @ L88self.condition.wait()
occ-001035slime/rollout/fully_async_rollout.py:133 · 快照AsyncRolloutWorker.load_state_dictinstance_candidateputinferred_receiver_candidate; queue.Queue @ L97self.output_queue.put(result)
occ-001036slime/rollout/fully_async_rollout.py:138 · 快照AsyncRolloutWorker.closeinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L106self.worker_thread.join(timeout=35)
occ-001037slime/rollout/fully_async_rollout.py:139 · 快照AsyncRolloutWorker.closeinstance_candidateis_aliveinferred_receiver_candidate; threading.Thread @ L106if self.worker_thread.is_alive():
occ-001038slime/rollout/fully_async_rollout.py:153 · 快照AsyncRolloutWorker.get_completed_groupsinstance_candidateget_nowaitinferred_receiver_candidate; queue.Queue @ L97completed.append(self.output_queue.get_nowait())
occ-001040slime/rollout/fully_async_rollout.py:159 · 快照AsyncRolloutWorker.queue_sizeinstance_candidateqsizeinferred_receiver_candidate; queue.Queue @ L97return self.output_queue.qsize()
occ-001042slime/rollout/fully_async_rollout.py:171 · 快照AsyncRolloutWorker._thread_maininstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L88self.condition.notify_all()
occ-001045slime/rollout/fully_async_rollout.py:182 · 快照AsyncRolloutWorker._loop.<comprehension>instance_candidatedoneunresolved_receiver_candidatedone = {t for t in active_tasks if t.done()}
occ-001046slime/rollout/fully_async_rollout.py:185 · 快照AsyncRolloutWorker._loopinstance_candidateresultunresolved_receiver_candidatet.result() # results already handled in callback
occ-001049slime/rollout/fully_async_rollout.py:199 · 快照AsyncRolloutWorker._loopinstance_candidateqsizeinferred_receiver_candidate; queue.Queue @ L97and self.output_queue.qsize() < max_concurrent
occ-001051slime/rollout/fully_async_rollout.py:217 · 快照AsyncRolloutWorker._loopinstance_candidateadd_done_callbackinferred_receiver_candidate; asyncio.Task @ L209task.add_done_callback(self._make_done_cb(gid))
occ-001052slime/rollout/fully_async_rollout.py:223 · 快照AsyncRolloutWorker._loopinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L88self.condition.notify_all()
occ-001058slime/rollout/fully_async_rollout.py:244 · 快照AsyncRolloutWorker._make_done_cb._cbinstance_candidateresultunresolved_receiver_candidateresult = done_task.result()
occ-001060slime/rollout/fully_async_rollout.py:261 · 快照AsyncRolloutWorker._make_done_cb._cbinstance_candidateexceptionunresolved_receiver_candidatelogger.exception(“fully-async: failed to requeue aborted group”)
occ-001061slime/rollout/fully_async_rollout.py:263 · 快照AsyncRolloutWorker._make_done_cb._cbinstance_candidateputinferred_receiver_candidate; queue.Queue @ L97self.output_queue.put((gid, result))
occ-001066slime/rollout/fully_async_rollout.py:321 · 快照_generate_rollout_asyncinstance_candidategetunresolved_receiver_candidatedrop_reasons[reason] = drop_reasons.get(reason, 0) + 1
occ-001072slime/rollout/on_policy_distillation.py:21 · 快照reward_funcinstance_candidategetunresolved_receiver_candidateif sample.multimodal_inputs and sample.multimodal_inputs.get(“images”):
occ-001085slime/rollout/rm_hub/init.py:66 · 快照async_rminstance_candidategetunresolved_receiver_candidaterm_type = (metadata.get(“rm_type”) or args.rm_type or “”).strip()
occ-001094slime/rollout/rm_hub/ifbench.py:132 · 快照_build_input_exampleinstance_candidategetunresolved_receiver_candidateinstruction_ids = _normalize_instruction_ids(metadata.get(“instruction_id_list”) or [])
occ-001095slime/rollout/rm_hub/ifbench.py:137 · 快照_build_input_exampleinstance_candidategetunresolved_receiver_candidateprompt_text = metadata.get(“prompt_text”)
occ-001096slime/rollout/rm_hub/ifbench.py:143 · 快照_build_input_exampleinstance_candidategetunresolved_receiver_candidateraw_kwargs = metadata.get(“kwargs”)
occ-001097slime/rollout/rm_hub/ifbench.py:147 · 快照_build_input_exampleinstance_candidategetunresolved_receiver_candidatekey=int(metadata.get(“record_id”) or 0),
occ-001106slime/rollout/sample_hooks.py:23 · 快照rollout_contextinstance_candidatesetinferred_receiver_candidate; contextvars.ContextVar @ L12token = _task_rollout_id.set(rollout_id)
occ-001107slime/rollout/sample_hooks.py:27 · 快照rollout_contextinstance_candidateresetinferred_receiver_candidate; contextvars.ContextVar @ L12_task_rollout_id.reset(token)
occ-001112slime/rollout/sample_hooks.py:58 · 快照apply_rollout_sample_hooksinstance_candidategetinferred_receiver_candidate; contextvars.ContextVar @ L12rollout_id = _task_rollout_id.get()
occ-001118slime/rollout/sglang_rollout.py:121 · 快照GenerateState.initinstance_candidateresetunresolved_receiver_candidateself.reset()
occ-001121slime/rollout/sglang_rollout.py:201 · 快照generateinstance_candidategetunresolved_receiver_candidateimages = sample.multimodal_inputs.get(“images”) if sample.multimodal_inputs else None
occ-001134slime/rollout/sglang_rollout.py:330 · 快照generate_and_rminstance_candidatewaitunresolved_receiver_candidateawait state.generation_pacer.wait()
occ-001146slime/rollout/sglang_rollout.py:436 · 快照abortinstance_candidatecancelunresolved_receiver_candidatetask.cancel()
occ-001155slime/rollout/sglang_rollout.py:461 · 快照abortinstance_candidateresultunresolved_receiver_candidategroup = task.result()
occ-001161slime/rollout/sglang_rollout.py:525 · 快照generate_rollout_asyncinstance_candidateresultunresolved_receiver_candidategroup: list[Sample] = task.result()
occ-001165slime/rollout/sglang_rollout.py:565 · 快照generate_rollout_asyncinstance_candidatecloseunresolved_receiver_candidatepbar.close()
occ-001167slime/rollout/sglang_rollout.py:575 · 快照generate_rollout_asyncinstance_candidateresetunresolved_receiver_candidatestate.reset()
occ-001179slime/rollout/sglang_rollout.py:740 · 快照eval_rollout_single_datasetinstance_candidatecloseunresolved_receiver_candidatepbar.close()
occ-001181slime/rollout/sglang_streaming_rollout.py:87 · 快照generate_streaminginstance_candidategetunresolved_receiver_candidateimages = sample.multimodal_inputs.get(“images”) if sample.multimodal_inputs else None
occ-001184slime/rollout/sglang_streaming_rollout.py:159 · 快照generate_streaminginstance_candidategetunresolved_receiver_candidateupdate_terminal_info=bool(last_meta_info.get(“finish_reason”)),
occ-001185slime/rollout/sglang_streaming_rollout.py:165 · 快照generate_streaminginstance_candidategetunresolved_receiver_candidateif last_meta_info.get(“finish_reason”):
occ-001186slime/rollout/sglang_streaming_rollout.py:171 · 快照generate_streaming.<lambda>instance_candidategetunresolved_receiver_candidateskip_special_tokens=sampling_params.get(“skip_special_tokens”, True),
occ-001187slime/rollout/sglang_streaming_rollout.py:175 · 快照generate_streaminginstance_candidategetunresolved_receiver_candidateif state.aborted and not last_meta_info.get(“finish_reason”):
occ-001188slime/rollout/sglang_streaming_rollout.py:177 · 快照generate_streaminginstance_candidategetunresolved_receiver_candidateelif not last_meta_info.get(“finish_reason”):
occ-001193slime/utils/accelerator/init.py:276 · 快照_make_selectedinstance_candidategetunresolved_receiver_candidateentry = _REGISTRY.get(name)
occ-001194slime/utils/accelerator/init.py:278 · 快照_make_selectedinstance_candidatejoinunresolved_receiver_candidateavailable = “, “.join(sorted(_REGISTRY))
occ-001195slime/utils/accelerator/init.py:332 · 快照get_acceleratorinstance_candidatejoinunresolved_receiver_candidateregistered = “, “.join(sorted(_REGISTRY))
occ-001200slime/utils/async_utils.py:26 · 快照AsyncPacer.waitinstance_candidatecreate_futureinferred_receiver_candidate; asyncio.AbstractEventLoop @ L25future = loop.create_future()
occ-001201slime/utils/async_utils.py:30 · 快照AsyncPacer.waitinstance_candidatecall_sooninferred_receiver_candidate; asyncio.AbstractEventLoop @ L25loop.call_soon(self._release)
occ-001203slime/utils/async_utils.py:36 · 快照AsyncPacer._releaseinstance_candidatedoneunresolved_receiver_candidateif not future.done():
occ-001204slime/utils/async_utils.py:37 · 快照AsyncPacer._releaseinstance_candidateset_resultunresolved_receiver_candidatefuture.set_result(None)
occ-001206slime/utils/async_utils.py:40 · 快照AsyncPacer._releaseinstance_candidatecall_laterinferred_receiver_candidate; asyncio.AbstractEventLoop @ L40asyncio.get_running_loop().call_later(0.001, self._release)
occ-001209slime/utils/async_utils.py:50 · 快照AsyncLoopThread.initinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L49self._thread.start()
occ-001211slime/utils/async_utils.py:54 · 快照AsyncLoopThread._start_loopinstance_candidaterun_foreverinferred_receiver_candidate; asyncio.AbstractEventLoop @ L48self.loop.run_forever()
occ-001213slime/utils/async_utils.py:58 · 快照AsyncLoopThread.runinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L58return asyncio.run_coroutine_threadsafe(coro, self.loop).result()
occ-001221slime/utils/health_monitor.py:29 · 快照RolloutHealthMonitor.initinstance_candidatesetinferred_receiver_candidate; threading.Event @ L28self._pause_event.set() # Engines may be offloaded before the first rollout.
occ-001223slime/utils/health_monitor.py:50 · 快照RolloutHealthMonitor.startinstance_candidateclearinferred_receiver_candidate; threading.Event @ L27self._stop_event.clear()
occ-001224slime/utils/health_monitor.py:51 · 快照RolloutHealthMonitor.startinstance_candidatesetinferred_receiver_candidate; threading.Event @ L28self._pause_event.set()
occ-001226slime/utils/health_monitor.py:58 · 快照RolloutHealthMonitor.startinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L53self._thread.start()
occ-001227slime/utils/health_monitor.py:68 · 快照RolloutHealthMonitor.stopinstance_candidatesetinferred_receiver_candidate; threading.Event @ L27self._stop_event.set()
occ-001228slime/utils/health_monitor.py:71 · 快照RolloutHealthMonitor.stopinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L53self._thread.join(timeout=timeout)
occ-001229slime/utils/health_monitor.py:72 · 快照RolloutHealthMonitor.stopinstance_candidateis_aliveinferred_receiver_candidate; threading.Thread @ L53if self._thread.is_alive():
occ-001230slime/utils/health_monitor.py:82 · 快照RolloutHealthMonitor.pauseinstance_candidatesetinferred_receiver_candidate; threading.Event @ L28self._pause_event.set()
occ-001231slime/utils/health_monitor.py:84 · 快照RolloutHealthMonitor.pauseinstance_candidateacquireinferred_receiver_candidate; threading.Lock @ L34if not self._check_lock.acquire(timeout=self._check_timeout if timeout is None else timeout):
occ-001232slime/utils/health_monitor.py:86 · 快照RolloutHealthMonitor.pauseinstance_candidatereleaseinferred_receiver_candidate; threading.Lock @ L34self._check_lock.release()
occ-001233slime/utils/health_monitor.py:92 · 快照RolloutHealthMonitor.resumeinstance_candidateclearinferred_receiver_candidate; threading.Event @ L28self._pause_event.clear()
occ-001234slime/utils/health_monitor.py:95 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L27while not self._stop_event.is_set():
occ-001235slime/utils/health_monitor.py:97 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L28while self._pause_event.is_set() and not self._stop_event.is_set():
occ-001236slime/utils/health_monitor.py:97 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L27while self._pause_event.is_set() and not self._stop_event.is_set():
occ-001237slime/utils/health_monitor.py:98 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L27self._stop_event.wait(timeout=0.5)
occ-001238slime/utils/health_monitor.py:100 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L27if self._stop_event.is_set():
occ-001239slime/utils/health_monitor.py:106 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L27if self._stop_event.wait(self._check_first_wait):
occ-001240slime/utils/health_monitor.py:109 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L28if self._pause_event.is_set():
occ-001241slime/utils/health_monitor.py:116 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L28if not self._pause_event.is_set() and not self._stop_event.is_set():
occ-001242slime/utils/health_monitor.py:116 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L27if not self._pause_event.is_set() and not self._stop_event.is_set():
occ-001243slime/utils/health_monitor.py:120 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidateexceptionunresolved_receiver_candidatelogger.exception(“Failed to unregister an unhealthy worker; retaining it for the next check”)
occ-001244slime/utils/health_monitor.py:123 · 快照RolloutHealthMonitor._health_monitor_loopinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L27if self._stop_event.wait(self._check_interval):
occ-001245slime/utils/health_monitor.py:134 · 快照RolloutHealthMonitor._run_health_checksinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L27if self._stop_event.is_set():
occ-001246slime/utils/health_monitor.py:136 · 快照RolloutHealthMonitor._run_health_checksinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L28if not force and self._pause_event.is_set():
occ-001261slime/utils/http_utils.py:282 · 快照_init_ray_distributed_post.<comprehension>instance_candidategetunresolved_receiver_candidatenodes = [n for n in ray.nodes() if n.get(“Alive”)]
occ-001269slime/utils/http_utils.py:368 · 快照getinstance_candidategetunresolved_receiver_candidateresponse = await _http_client.get(url, timeout=timeout)
occ-001277slime/utils/reloadable_process_group.py:79 · 快照_destroy_default_accelerator_process_groupinstance_candidategetunresolved_receiver_candidatestate = default_process_group_states.get(os.getpid())
occ-001279slime/utils/reloadable_process_group.py:109 · 快照_reload_default_process_groupinstance_candidategetunresolved_receiver_candidatestate = default_process_group_states.get(os.getpid())
occ-001282slime/utils/reloadable_process_group.py:158 · 快照monkey_patch_torch_dist.new_groupinstance_candidategetunresolved_receiver_candidateexplicit_backend = args[2] if len(args) >= 3 else kwargs.get(“backend”)
occ-001285slime/utils/reloadable_process_group.py:311 · 快照ReloadableProcessGroup.destroy_process_groupsinstance_candidategetunresolved_receiver_candidatefor reloadable_group in ReloadableProcessGroup.GROUPS.get(pid, []):
occ-001287slime/utils/reloadable_process_group.py:329 · 快照ReloadableProcessGroup.invalidate_process_groupsinstance_candidategetunresolved_receiver_candidatefor reloadable_group in ReloadableProcessGroup.GROUPS.get(pid, []):
occ-001289slime/utils/reloadable_process_group.py:335 · 快照ReloadableProcessGroup.reload_process_groupsinstance_candidategetunresolved_receiver_candidatereloadable_groups = ReloadableProcessGroup.GROUPS.get(pid, [])
occ-001290slime/utils/reloadable_process_group.py:339 · 快照ReloadableProcessGroup.reload_process_groupsinstance_candidategetunresolved_receiver_candidatebackend_counts[backend] = backend_counts.get(backend, 0) + 1
occ-001291slime/utils/reloadable_process_group.py:346 · 快照ReloadableProcessGroup.reload_process_groupsinstance_candidategetunresolved_receiver_candidateold_new_group = old_new_group_dict.get(pid)
occ-001292slime/utils/reloadable_process_group.py:367 · 快照ReloadableProcessGroup.shutdowninstance_candidateshutdownunresolved_receiver_candidateself.group.shutdown()
occ-001293slime/utils/reloadable_process_group.py:371 · 快照ReloadableProcessGroup.abortinstance_candidateabortunresolved_receiver_candidateself.group.abort()
occ-001294slime/utils/reloadable_process_group.py:470 · 快照destroy_process_groupsinstance_candidategetunresolved_receiver_candidatestate = default_process_group_states.get(os.getpid())
occ-001300slime/utils/routed_experts.py:174 · 快照RoutedExpertsMicrobatchPrefetcher.begin_passinstance_candidatestartunresolved_receiver_candidateself.start()
occ-001302slime/utils/routed_experts.py:189 · 快照RoutedExpertsMicrobatchPrefetcher.closeinstance_candidateshutdownunresolved_receiver_candidateself._executor.shutdown(wait=True, cancel_futures=True)
occ-001303slime/utils/routed_experts.py:191 · 快照RoutedExpertsMicrobatchPrefetcher.closeinstance_candidatereleaseunresolved_receiver_candidatesource.release()
occ-001306slime/utils/routed_experts.py:235 · 快照RoutedExpertsMicrobatch.prefetchinstance_candidatesubmitunresolved_receiver_candidateself._future = executor.submit(self._load_and_prepare)
occ-001307slime/utils/routed_experts.py:242 · 快照RoutedExpertsMicrobatch._get_cpu_tensorinstance_candidateresultunresolved_receiver_candidatetensor = future.result() if future is not None else self._load_and_prepare()
occ-001308slime/utils/routed_experts.py:262 · 快照RoutedExpertsMicrobatch.layer_to_cudainstance_candidatereleaseunresolved_receiver_candidateself.release()
occ-001309slime/utils/routed_experts.py:270 · 快照RoutedExpertsMicrobatch.releaseinstance_candidatedoneunresolved_receiver_candidateif future is not None and not future.done():
occ-001310slime/utils/routed_experts.py:271 · 快照RoutedExpertsMicrobatch.releaseinstance_candidatecancelunresolved_receiver_candidatefuture.cancel()
occ-001316slime_plugins/rollout_buffer/buffer.py:242 · 快照RolloutBuffer.writeinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L233self.not_empty.notify_all()
occ-001317slime_plugins/rollout_buffer/buffer.py:251 · 快照RolloutBuffer.readinstance_candidategetunresolved_receiver_candidateresult = self.buffer.get()
occ-001320slime_plugins/rollout_buffer/buffer.py:263 · 快照write_to_bufferinstance_candidatewriteunresolved_receiver_candidateitem = buffer.write(data)
occ-001322slime_plugins/rollout_buffer/buffer.py:279 · 快照get_rollout_datainstance_candidatereadunresolved_receiver_candidateitems = buffer.read()
occ-001323slime_plugins/rollout_buffer/buffer.py:315 · 快照run_rolloutinstance_candidategetunresolved_receiver_candidatetransform_group_func=generator_info.get(“transform_group”, None),
occ-001324slime_plugins/rollout_buffer/buffer.py:316 · 快照run_rolloutinstance_candidategetunresolved_receiver_candidateis_valid_group_func=generator_info.get(“is_valid_group”),
occ-001325slime_plugins/rollout_buffer/buffer.py:317 · 快照run_rolloutinstance_candidategetunresolved_receiver_candidateget_group_data_meta_info_func=generator_info.get(“get_group_data_meta_info”),
occ-001333slime_plugins/rollout_buffer/generator/base_generator.py:138 · 快照worker_processinstance_candidateputunresolved_receiver_candidatedone_queue.put(output_item)
occ-001334slime_plugins/rollout_buffer/generator/base_generator.py:140 · 快照worker_processinstance_candidateputunresolved_receiver_candidatedone_queue.put(“COMPLETE”)
occ-001337slime_plugins/rollout_buffer/generator/base_generator.py:224 · 快照BaseGenerator.run.read_data_into_queueinstance_candidateputunresolved_receiver_candidatetask_queue.put(item_repeat)
occ-001339slime_plugins/rollout_buffer/generator/base_generator.py:235 · 快照BaseGenerator.run.read_data_into_queueinstance_candidateputunresolved_receiver_candidatetask_queue.put(“STOP”)
occ-001341slime_plugins/rollout_buffer/generator/base_generator.py:245 · 快照BaseGenerator.runinstance_candidatestartinferred_receiver_candidate; multiprocessing.Process @ L241process.start()
occ-001343slime_plugins/rollout_buffer/generator/base_generator.py:249 · 快照BaseGenerator.runinstance_candidatestartinferred_receiver_candidate; multiprocessing.Process @ L248process.start()
occ-001344slime_plugins/rollout_buffer/generator/base_generator.py:254 · 快照BaseGenerator.runinstance_candidategetunresolved_receiver_candidateitem = done_queue.get()
occ-001345slime_plugins/rollout_buffer/generator/base_generator.py:263 · 快照BaseGenerator.runinstance_candidatecloseunresolved_receiver_candidateprogress_bar.close()
occ-001347slime_plugins/rollout_buffer/generator/base_generator.py:292 · 快照run_rolloutinstance_candidategetunresolved_receiver_candidatenum_process=int(data.get(“num_process”, 100)),
occ-001348slime_plugins/rollout_buffer/generator/base_generator.py:294 · 快照run_rolloutinstance_candidategetunresolved_receiver_candidateskip_instance_ids=data.get(“skip_instance_ids”, None),
occ-001349slime_plugins/rollout_buffer/generator/base_generator.py:297 · 快照run_rolloutinstance_candidategetunresolved_receiver_candidategenerator.entry(data[“input_file”], rollout_func, reward_func, int(data.get(“num_epoch”, 1)))
occ-001366tests/ci/gpu_lock_exec.py:26 · 快照maininstance_candidatejoinunresolved_receiver_candidatedev_list = “,".join(str(x.gpu_id) for x in fd_locks)
occ-001367tests/ci/gpu_lock_exec.py:34 · 快照maininstance_candidatecloseunresolved_receiver_candidatefd_lock.close()
occ-001369tests/ci/gpu_lock_exec.py:46 · 快照_run_command.terminate_childinstance_candidatepollinferred_receiver_candidate; subprocess.Popen @ L43if child.poll() is None:
occ-001370tests/ci/gpu_lock_exec.py:47 · 快照_run_command.terminate_childinstance_candidateterminateinferred_receiver_candidate; subprocess.Popen @ L43child.terminate()
occ-001371tests/ci/gpu_lock_exec.py:49 · 快照_run_command.terminate_childinstance_candidatewaitinferred_receiver_candidate; subprocess.Popen @ L43child.wait(timeout=5)
occ-001374tests/ci/gpu_lock_exec.py:59 · 快照_run_command.terminate_childinstance_candidatewaitinferred_receiver_candidate; subprocess.Popen @ L43child.wait(timeout=5)
occ-001378tests/ci/gpu_lock_exec.py:65 · 快照_run_command.terminate_childinstance_candidatewaitinferred_receiver_candidate; subprocess.Popen @ L43child.wait()
occ-001384tests/ci/gpu_lock_exec.py:75 · 快照_run_commandinstance_candidatepollinferred_receiver_candidate; subprocess.Popen @ L43returncode = child.poll()
occ-001389tests/ci/gpu_lock_exec.py:131 · 快照_execute_print_onlyinstance_candidatecloseunresolved_receiver_candidatefd_lock.close()
occ-001390tests/ci/gpu_lock_exec.py:135 · 快照_execute_print_onlyinstance_candidatejoinunresolved_receiver_candidateprint(“Free GPUs:”, “,".join(str(x) for x in free), flush=True)
occ-001392tests/ci/gpu_lock_exec.py:167 · 快照_try_acquire_specificinstance_candidatecloseunresolved_receiver_candidatefd_lock.close()
occ-001393tests/ci/gpu_lock_exec.py:182 · 快照_try_acquire_countinstance_candidatecloseunresolved_receiver_candidatefd_lock.close()
occ-001394tests/ci/gpu_lock_exec.py:191 · 快照_try_acquire_countinstance_candidatecloseunresolved_receiver_candidatefd_lock.close()
occ-001399tests/ci/gpu_lock_exec.py:218 · 快照FdLock.closeinstance_candidatecloseunresolved_receiver_candidateself.fd.close()
occ-001400tests/ci/gpu_lock_exec.py:231 · 快照_ensure_lock_filesinstance_candidatecloseunresolved_receiver_candidateopen(p, “a”).close()
occ-001402tests/fanout_test_helpers.py:52 · 快照compact_generateinstance_candidatewriteunresolved_receiver_candidatef.write(f”{sample.index}\n”)
occ-001409tests/pipeline_rl_test_helpers.py:76 · 快照GenerationProbe.runinstance_candidategetunresolved_receiver_candidate“finish_reason”: meta.get(“finish_reason”),
occ-001410tests/pipeline_rl_test_helpers.py:80 · 快照GenerationProbe.runinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L46self.condition.notify_all()
occ-001411tests/pipeline_rl_test_helpers.py:86 · 快照GenerationProbe.runinstance_candidatenotify_allinferred_receiver_candidate; threading.Condition @ L46self.condition.notify_all()
occ-001412tests/pipeline_rl_test_helpers.py:90 · 快照GenerationProbe.waitinstance_candidatewait_forinferred_receiver_candidate; threading.Condition @ L46ready = self.condition.wait_for(lambda: self.error or self.done or predicate(self.events), timeout=180)
occ-001413tests/pipeline_rl_test_helpers.py:97 · 快照GenerationProbe.verifyinstance_candidatewaitunresolved_receiver_candidateself.wait(
occ-001414tests/pipeline_rl_test_helpers.py:110 · 快照GenerationProbe.verifyinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L49self.thread.join(timeout=30)
occ-001415tests/pipeline_rl_test_helpers.py:111 · 快照GenerationProbe.verifyinstance_candidateis_aliveinferred_receiver_candidate; threading.Thread @ L49assert not self.thread.is_alive()
occ-001416tests/pipeline_rl_test_helpers.py:115 · 快照GenerationProbe.verify_flushinstance_candidatewaitunresolved_receiver_candidateself.wait(lambda events: bool(events) and events[-1][“finish_reason”] is not None)
occ-001417tests/pipeline_rl_test_helpers.py:116 · 快照GenerationProbe.verify_flushinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L49self.thread.join(timeout=30)
occ-001418tests/pipeline_rl_test_helpers.py:117 · 快照GenerationProbe.verify_flushinstance_candidateis_aliveinferred_receiver_candidate; threading.Thread @ L49assert not self.thread.is_alive()
occ-001419tests/pipeline_rl_test_helpers.py:132 · 快照start_probesinstance_candidateclearunresolved_receiver_candidate_probes.clear()
occ-001420tests/pipeline_rl_test_helpers.py:136 · 快照start_probesinstance_candidatestartunresolved_receiver_candidateprobe.thread.start()
occ-001421tests/pipeline_rl_test_helpers.py:138 · 快照start_probesinstance_candidatewaitunresolved_receiver_candidateprobe.wait(lambda events: bool(events) and events[-1][“tokens”] >= 16)
occ-001423tests/pipeline_rl_test_helpers.py:160 · 快照before_train_stepinstance_candidatemapinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L159_records[“continuous”] = list(pool.map(lambda probe: probe.verify(), _probes))
occ-001425tests/pipeline_rl_test_helpers.py:166 · 快照before_train_stepinstance_candidatemapinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L164pool.map(
occ-001438tests/plugin_contracts/test_plugin_path_loading_contracts.py:123 · 快照reference_dynamic_filter.<comprehension>instance_candidategetunresolved_receiver_candidatekeep = not any(sample.metadata.get(“drop”) for sample in samples)
occ-001449tests/test_agent/_fakes.py:82 · 快照FakeTokenizer.decodeinstance_candidatejoinunresolved_receiver_candidatereturn " “.join(self._inv[i] for i in ids if i in self._inv and i not in _SPECIAL_IDS)
occ-001450tests/test_agent/_fakes.py:86 · 快照FakeTokenizer._content_textinstance_candidategetunresolved_receiver_candidatec = message.get(“content”)
occ-001451tests/test_agent/_fakes.py:88 · 快照FakeTokenizer._content_textinstance_candidategetunresolved_receiver_candidatereasoning = message.get(“reasoning_content”)
occ-001452tests/test_agent/_fakes.py:95 · 快照FakeTokenizer._content_textinstance_candidategetunresolved_receiver_candidateif isinstance(b, dict) and b.get(“type”) == “text”:
occ-001453tests/test_agent/_fakes.py:96 · 快照FakeTokenizer._content_textinstance_candidategetunresolved_receiver_candidateparts.append(str(b.get(“text”, “”)))
occ-001454tests/test_agent/_fakes.py:97 · 快照FakeTokenizer._content_textinstance_candidategetunresolved_receiver_candidatefor call in message.get(“tool_calls”) or []:
occ-001455tests/test_agent/_fakes.py:98 · 快照FakeTokenizer._content_textinstance_candidategetunresolved_receiver_candidatefn = call.get(“function”) or {}
occ-001456tests/test_agent/_fakes.py:99 · 快照FakeTokenizer._content_textinstance_candidategetunresolved_receiver_candidateparts.append(f"toolcall:{fn.get(’name’, ‘’)}”)
occ-001457tests/test_agent/_fakes.py:100 · 快照FakeTokenizer._content_textinstance_candidatejoinunresolved_receiver_candidatereturn " “.join(p for p in parts if p)
occ-001458tests/test_agent/_fakes.py:106 · 快照FakeTokenizer.apply_chat_templateinstance_candidategetunresolved_receiver_candidaterole = m.get(“role”, “user”)
occ-001459tests/test_agent/_fakes.py:107 · 快照FakeTokenizer.apply_chat_templateinstance_candidategetunresolved_receiver_candidateout.append(_ROLE_BEGIN.get(role, _ROLE_BEGIN[“user”]))
occ-001460tests/test_agent/_fakes.py:132 · 快照ScriptedTokenizer.decodeinstance_candidategetunresolved_receiver_candidatereturn self.outputs.get(tuple(ids), “”)
occ-001462tests/test_agent/_fakes.py:158 · 快照FakeSGLangServer._handleinstance_candidategetunresolved_receiver_candidateself.routing_keys.append(request.headers.get(“X-SMG-Routing-Key”))
occ-001468tests/test_agent/_fakes.py:183 · 快照FakeSGLangServer.aexitinstance_candidatecloseunresolved_receiver_candidateawait self._server.close()
occ-001477tests/test_agent/_fakes.py:294 · 快照FakeSandbox.read_fileinstance_candidategetunresolved_receiver_candidatereturn _as_str(self.files.get(sandbox_path, “”))
occ-001479tests/test_agent/test_adapters.py:57 · 快照_parse_sse.flushinstance_candidatejoinunresolved_receiver_candidatedata = “\n”.join(data_lines)
occ-001488tests/test_agent/test_adapters.py:184 · 快照test_anthropic_messages_nonstream_records_token_segments.run_caseinstance_candidatecloseunresolved_receiver_candidateawait client.close()
occ-001497tests/test_agent/test_adapters.py:220 · 快照test_openai_chat_completions_nonstream_records_token_segments.run_caseinstance_candidatecloseunresolved_receiver_candidateawait client.close()
occ-001506tests/test_agent/test_adapters.py:259 · 快照test_anthropic_messages_streams_blocks.run_caseinstance_candidatecloseunresolved_receiver_candidateawait client.close()
occ-001508tests/test_agent/test_adapters.py:267 · 快照test_anthropic_messages_streams_blocks.run_case.<comprehension>instance_candidategetunresolved_receiver_candidateassert any(d[“delta”].get(“text”) == “streamed” for d in deltas)
occ-001516tests/test_agent/test_adapters.py:288 · 快照test_openai_chat_completions_streams_chunks_until_done.run_caseinstance_candidatecloseunresolved_receiver_candidateawait client.close()
occ-001527tests/test_agent/test_adapters.py:358 · 快照test_anthropic_multiturn_wire_roundtrip_and_token_capture.run_caseinstance_candidatecloseunresolved_receiver_candidateawait client.close()
occ-001536tests/test_agent/test_adapters.py:397 · 快照test_max_turns_per_sid_returns_429.run_caseinstance_candidatecloseunresolved_receiver_candidateawait client.close()
occ-001539tests/test_agent/test_adapters.py:418 · 快照test_mid_list_system_folds_into_user.<comprehension>instance_candidategetunresolved_receiver_candidateassert any(b.get(“text”, “”).startswith("<system-reminder>”) for b in folded)
occ-001557tests/test_agent/test_agent_rollout_cpu.py:188 · 快照test_generate_produces_trained_samples.run_caseinstance_candidategetunresolved_receiver_candidateassert s.metadata.get(“agent_exit_code”) == 0
occ-001562tests/test_agent/test_agent_rollout_cpu.py:213 · 快照test_generate_aborts_on_empty_trajectory.run_caseinstance_candidategetunresolved_receiver_candidateassert samples[0].metadata.get(“abort_reason”) == “adapter_session_empty”
occ-001566tests/test_agent/test_agent_rollout_cpu.py:227 · 快照test_generate_aborts_on_missing_image.run_caseinstance_candidategetunresolved_receiver_candidateassert samples[0].metadata.get(“abort_reason”) == “missing_image_or_workdir”
occ-001572tests/test_agent/test_agent_rollout_cpu.py:251 · 快照_codex_agentinstance_candidategetunresolved_receiver_candidatehistory.append({“role”: “assistant”, “content”: msg.get(“content”) or “”})
occ-001576tests/test_agent/test_agent_rollout_cpu.py:284 · 快照test_codex_openai_rollout_closes_loop.run_caseinstance_candidatestopunresolved_receiver_candidatehandle.stop()
occ-001595tests/test_agent/test_harness.py:110 · 快照test_claude_code_write_config_preacks_bypass_permissions.run_caseinstance_candidatejoinunresolved_receiver_candidatejoined = " “.join(cmd for cmd, _ in sb.exec_log)
occ-001614tests/test_agent/test_harness.py:227 · 快照test_base_harness_run_calls_steps_in_order.run_caseinstance_candidatejoinunresolved_receiver_candidatejoined = " “.join(c for c, _ in sb.exec_log)
occ-001621tests/test_agent/test_sandbox_exec_and_wait.py:69 · 快照ShellFakeSandbox.read_fileinstance_candidategetunresolved_receiver_candidatereturn self.files.get(path, “”)
occ-001623tests/test_agent/test_sandbox_exec_and_wait.py:83 · 快照ShellFakeSandbox.execinstance_candidategetunresolved_receiver_candidatereturn 0, self.files.get(tail.group(1), “”)[-512:], "”
occ-001638tests/test_distributed_rollout.py:88 · 快照source_factoryinstance_candidatecloseunresolved_receiver_candidatesource.close()
occ-001639tests/test_distributed_rollout.py:89 · 快照source_factoryinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001640tests/test_distributed_rollout.py:115 · 快照test_task_claims_and_producer_cursor_survive_recoveryinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001641tests/test_distributed_rollout.py:127 · 快照test_task_claims_and_producer_cursor_survive_recoveryinstance_candidatecloseunresolved_receiver_candidaterestored.close()
occ-001642tests/test_distributed_rollout.py:148 · 快照test_whole_job_recovery_replays_accepted_results_and_durable_continuationsinstance_candidatecloseunresolved_receiver_candidatereader.close()
occ-001643tests/test_distributed_rollout.py:150 · 快照test_whole_job_recovery_replays_accepted_results_and_durable_continuationsinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001644tests/test_distributed_rollout.py:157 · 快照test_whole_job_recovery_replays_accepted_results_and_durable_continuationsinstance_candidateacquireunresolved_receiver_candidateassignment = restored.queue.acquire(“new-reader”, 1, task_ids=[task_id]).assignments[0]
occ-001645tests/test_distributed_rollout.py:170 · 快照test_whole_job_recovery_replays_accepted_results_and_durable_continuationsinstance_candidatecloseunresolved_receiver_candidaterestored.close()
occ-001646tests/test_distributed_rollout.py:235 · 快照test_generation_workers_cannot_claim_manager_collection_tasksinstance_candidateacquireunresolved_receiver_candidatecollection = controller.queue.acquire(“manager”, 1, task_ids=[task_id])
occ-001647tests/test_distributed_rollout.py:264 · 快照test_manager_replacement_fences_readers_and_recovers_only_unused_resultsinstance_candidatecloseunresolved_receiver_candidatereader.close()
occ-001648tests/test_distributed_rollout.py:265 · 快照test_manager_replacement_fences_readers_and_recovers_only_unused_resultsinstance_candidatecloseunresolved_receiver_candidateold.close()
occ-001649tests/test_distributed_rollout.py:266 · 快照test_manager_replacement_fences_readers_and_recovers_only_unused_resultsinstance_candidatecloseunresolved_receiver_candidaterebuilt.close()
occ-001650tests/test_distributed_rollout.py:404 · 快照test_lost_return_reply_preserves_one_pending_taskinstance_candidatecloseunresolved_receiver_candidatereader.close()
occ-001651tests/test_distributed_rollout.py:505 · 快照test_legacy_rollout_return_completes_borrowed_inputsinstance_candidatecloseunresolved_receiver_candidatereader.close()
occ-001652tests/test_distributed_rollout.py:523 · 快照test_checkpoint_buffer_and_latest_continuation_survive_reader_releaseinstance_candidatecloseunresolved_receiver_candidatesource.close()
occ-001653tests/test_distributed_rollout.py:558 · 快照test_buffer_checkpoint_reuses_durable_groups_and_protects_them_from_gc.<comprehension>instance_candidategetunresolved_receiver_candidatetasks = [task for task in checkpoint[“pending”].load()[“tasks”] if task[“metadata”].get(“returned”)]
occ-001654tests/test_distributed_rollout.py:566 · 快照test_buffer_checkpoint_reuses_durable_groups_and_protects_them_from_gcinstance_candidatecloseunresolved_receiver_candidatereader.close()
occ-001655tests/test_distributed_rollout.py:580 · 快照test_pending_checkpoint_reuses_inputs_without_reserving_leasesinstance_candidatecloseunresolved_receiver_candidatereader.close()
occ-001658tests/test_distributed_rollout.py:605 · 快照test_slow_task_acquire_does_not_block_async_generation.takeinstance_candidatesetunresolved_receiver_candidateentered.set()
occ-001659tests/test_distributed_rollout.py:606 · 快照test_slow_task_acquire_does_not_block_async_generation.takeinstance_candidatewaitunresolved_receiver_candidateif not release.wait(10):
occ-001662tests/test_distributed_rollout.py:616 · 快照test_slow_task_acquire_does_not_block_async_generation.exerciseinstance_candidateis_setunresolved_receiver_candidateif entered.is_set():
occ-001665tests/test_distributed_rollout.py:619 · 快照test_slow_task_acquire_does_not_block_async_generation.exerciseinstance_candidateis_setunresolved_receiver_candidateassert entered.is_set()
occ-001666tests/test_distributed_rollout.py:620 · 快照test_slow_task_acquire_does_not_block_async_generation.exerciseinstance_candidatedoneinferred_receiver_candidate; asyncio.Task @ L613assert not task.done()
occ-001667tests/test_distributed_rollout.py:622 · 快照test_slow_task_acquire_does_not_block_async_generation.exerciseinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-001673tests/test_distributed_rollout.py:655 · 快照scheduler_factory.killinstance_candidatecall_soon_threadsafeunresolved_receiver_candidateloop.call_soon_threadsafe(worker.actor.producer.cancel)
occ-001674tests/test_distributed_rollout.py:658 · 快照scheduler_factory.<lambda>instance_candidateresultunresolved_receiver_candidatemonkeypatch.setattr(ray, “get”, lambda ref: ref.result())
occ-001675tests/test_distributed_rollout.py:659 · 快照scheduler_factory.<lambda>instance_candidatecancelunresolved_receiver_candidatemonkeypatch.setattr(ray, “cancel”, lambda ref: ref.cancel())
occ-001678tests/test_distributed_rollout.py:687 · 快照scheduler_factory.create.make_generator.executeinstance_candidateis_setinferred_receiver_candidate; threading.Event @ L672while not release.is_set():
occ-001682tests/test_distributed_rollout.py:727 · 快照scheduler_factoryinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-001683tests/test_distributed_rollout.py:729 · 快照scheduler_factoryinstance_candidatecloseunresolved_receiver_candidatescheduler.close()
occ-001685tests/test_distributed_rollout.py:734 · 快照scheduler_factory.cleanupinstance_candidatecancelunresolved_receiver_candidateproducer.cancel()
occ-001689tests/test_distributed_rollout.py:737 · 快照scheduler_factoryinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L737asyncio.run_coroutine_threadsafe(cleanup(), loop).result(timeout=10)
occ-001692tests/test_distributed_rollout.py:794 · 快照test_async_scheduler_fast_worker_fills_batch_without_waiting_for_slow_workerinstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L793future = consumer.submit(scheduler.generate, 0, prefetch=2)
occ-001693tests/test_distributed_rollout.py:796 · 快照test_async_scheduler_fast_worker_fills_batch_without_waiting_for_slow_workerinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L794result = future.result(timeout=5)
occ-001695tests/test_distributed_rollout.py:804 · 快照test_async_scheduler_fast_worker_fills_batch_without_waiting_for_slow_workerinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-001698tests/test_distributed_rollout.py:815 · 快照test_slow_worker_control_does_not_block_collection_or_close.stallinstance_candidatesetinferred_receiver_candidate; threading.Event @ L811entered.set()
occ-001700tests/test_distributed_rollout.py:823 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L821callers.submit(scheduler.generate, 0, prefetch=2)
occ-001701tests/test_distributed_rollout.py:825 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L821else callers.submit(scheduler.pause)
occ-001702tests/test_distributed_rollout.py:829 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L811assert entered.wait(5)
occ-001703tests/test_distributed_rollout.py:831 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidateresultunresolved_receiver_candidateresult = request.result(timeout=2)
occ-001704tests/test_distributed_rollout.py:833 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L821closing = callers.submit(scheduler.close)
occ-001705tests/test_distributed_rollout.py:834 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L833closing.result(timeout=2)
occ-001706tests/test_distributed_rollout.py:837 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidateresultunresolved_receiver_candidaterequest.result(timeout=2)
occ-001707tests/test_distributed_rollout.py:840 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidatedoneinferred_receiver_candidate; concurrent.futures.Future @ L810if not stalled.done():
occ-001708tests/test_distributed_rollout.py:841 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidateset_resultinferred_receiver_candidate; concurrent.futures.Future @ L810stalled.set_result(None)
occ-001709tests/test_distributed_rollout.py:843 · 快照test_slow_worker_control_does_not_block_collection_or_closeinstance_candidatecloseunresolved_receiver_candidatescheduler.close()
occ-001711tests/test_distributed_rollout.py:885 · 快照test_scheduler_close_unblocks_waiting_consumerinstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L884future = consumer.submit(scheduler.generate, 0, prefetch=1)
occ-001712tests/test_distributed_rollout.py:891 · 快照test_scheduler_close_unblocks_waiting_consumerinstance_candidatewaitunresolved_receiver_candidatescheduler.condition.wait(timeout=0.01)
occ-001713tests/test_distributed_rollout.py:892 · 快照test_scheduler_close_unblocks_waiting_consumerinstance_candidatecloseunresolved_receiver_candidatescheduler.close()
occ-001714tests/test_distributed_rollout.py:894 · 快照test_scheduler_close_unblocks_waiting_consumerinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L885future.result(timeout=5)
occ-001715tests/test_distributed_rollout.py:898 · 快照test_scheduler_close_unblocks_waiting_consumerinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-001723tests/test_distributed_rollout.py:990 · 快照test_worker_refills_locally_and_slow_group_does_not_block_results.generate_groupinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L977await release.wait()
occ-001733tests/test_distributed_rollout.py:1013 · 快照test_worker_refills_locally_and_slow_group_does_not_block_results.exerciseinstance_candidateis_setinferred_receiver_candidate; asyncio.Event @ L977assert not release.is_set()
occ-001741tests/test_distributed_rollout.py:1027 · 快照test_worker_refills_locally_and_slow_group_does_not_block_results.exerciseinstance_candidatesetinferred_receiver_candidate; asyncio.Event @ L977release.set()
occ-001744tests/test_distributed_rollout.py:1032 · 快照test_worker_refills_locally_and_slow_group_does_not_block_results.exerciseinstance_candidatedoneunresolved_receiver_candidateassert worker.producer.done()
occ-001745tests/test_distributed_rollout.py:1036 · 快照test_worker_refills_locally_and_slow_group_does_not_block_results.exerciseinstance_candidatecancelunresolved_receiver_candidateworker.producer.cancel()
occ-001756tests/test_distributed_rollout.py:1154 · 快照_rollout_argsinstance_candidatejoinunresolved_receiver_candidatedataset.write_text("\n”.join(json.dumps({“text”: f"hello {i}”}) for i in range(7)))
occ-001757tests/test_distributed_rollout.py:1438 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidatecloseunresolved_receiver_candidatesource.close()
occ-001758tests/test_distributed_rollout.py:1467 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidateclearunresolved_receiver_candidateruntime.ready.clear()
occ-001760tests/test_distributed_rollout.py:1472 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L1471future = consumer.submit(fetch, 2)
occ-001761tests/test_distributed_rollout.py:1478 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidatewaitunresolved_receiver_candidateruntime.condition.wait(timeout=0.01)
occ-001762tests/test_distributed_rollout.py:1494 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidatewaitunresolved_receiver_candidateruntime.condition.wait(timeout=0.01)
occ-001763tests/test_distributed_rollout.py:1498 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L1472after_failure = future.result(timeout=30)
occ-001764tests/test_distributed_rollout.py:1511 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidatecloseunresolved_receiver_candidatesource.close()
occ-001765tests/test_distributed_rollout.py:1521 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidateclearunresolved_receiver_candidateruntime.ready.clear()
occ-001766tests/test_distributed_rollout.py:1532 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidatewaitunresolved_receiver_candidateruntime.condition.wait(timeout=0.1)
occ-001767tests/test_distributed_rollout.py:1538 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidatecloseunresolved_receiver_candidatesource.close()
occ-001768tests/test_distributed_rollout.py:1540 · 快照test_two_ray_nodes_generate_transfer_and_restoreinstance_candidateshutdownunresolved_receiver_candidatecluster.shutdown()
occ-001769tests/test_distributed_rollout.py:1659 · 快照test_restore_source_handoff_releases_obsolete_snapshot_graphsinstance_candidatereleaseunresolved_receiver_candidatestore.release(“checkpoint:old”)
occ-001770tests/test_distributed_rollout.py:1720 · 快照test_restore_source_handoff_preserves_lazy_consumers_and_failed_saveinstance_candidatereleaseunresolved_receiver_candidatestore.release(“checkpoint:old”)
occ-001771tests/test_distributed_rollout.py:1730 · 快照test_restore_source_handoff_preserves_lazy_consumers_and_failed_saveinstance_candidatereleaseunresolved_receiver_candidatestore.release(saved[“storage_owner”])
occ-001772tests/test_distributed_rollout.py:1776 · 快照test_restore_source_handoff_preserves_prefix_before_later_accepted_resultinstance_candidatereleaseunresolved_receiver_candidatecontroller.store.release(“checkpoint:old”)
occ-001777tests/test_distributed_rollout.py:1833 · 快照test_cancelled_rebuffer_waiter_does_not_drop_its_continuation.exerciseinstance_candidatecancelunresolved_receiver_candidatewaiters[0].cancel()
occ-001781tests/test_distributed_rollout.py:1891 · 快照test_shutdown_allows_large_buffers_and_propagates_deadline_failureinstance_candidatecloseunresolved_receiver_candidatescheduler.close()
occ-001782tests/test_distributed_rollout.py:1893 · 快照test_shutdown_allows_large_buffers_and_propagates_deadline_failureinstance_candidatecloseunresolved_receiver_candidatescheduler.close()
occ-001783tests/test_distributed_rollout.py:1934 · 快照test_online_gc_waits_for_training_completion_and_checkpoint_releaseinstance_candidatereleaseunresolved_receiver_candidatecontroller.store.release(“checkpoint:test”)
occ-001784tests/test_distributed_rollout.py:1981 · 快照test_joint_restore_starts_gc_only_after_consumer_state_is_durableinstance_candidateis_aliveunresolved_receiver_candidateassert controller._gc_thread.is_alive()
occ-001785tests/test_distributed_rollout.py:1986 · 快照test_joint_restore_starts_gc_only_after_consumer_state_is_durableinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001786tests/test_distributed_rollout.py:1998 · 快照test_background_gc_failure_stops_queue_work_and_fails_closeinstance_candidateacquireunresolved_receiver_candidatelease = queue.acquire(“reader”).assignments[0].lease
occ-001788tests/test_distributed_rollout.py:2011 · 快照test_background_gc_failure_stops_queue_work_and_fails_closeinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L2010controller._gc_thread.start()
occ-001789tests/test_distributed_rollout.py:2012 · 快照test_background_gc_failure_stops_queue_work_and_fails_closeinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L2010controller._gc_thread.join(5)
occ-001790tests/test_distributed_rollout.py:2013 · 快照test_background_gc_failure_stops_queue_work_and_fails_closeinstance_candidateis_aliveinferred_receiver_candidate; threading.Thread @ L2010assert not controller._gc_thread.is_alive()
occ-001791tests/test_distributed_rollout.py:2014 · 快照test_background_gc_failure_stops_queue_work_and_fails_closeinstance_candidateis_setunresolved_receiver_candidateassert controller._gc_stop.is_set() and calls == [“collect”]
occ-001792tests/test_distributed_rollout.py:2039 · 快照test_background_gc_failure_stops_queue_work_and_fails_closeinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001793tests/test_distributed_rollout.py:2041 · 快照test_background_gc_failure_stops_queue_work_and_fails_closeinstance_candidatereadunresolved_receiver_candidateassert next(controller.store.read(ref)).payload == b"still protected”
occ-001795tests/test_distributed_rollout.py:2050 · 快照test_admission_pause_acknowledges_workers_without_waiting_for_responsesinstance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L2049paused = pool.submit(scheduler.pause, drain=False)
occ-001796tests/test_distributed_rollout.py:2052 · 快照test_admission_pause_acknowledges_workers_without_waiting_for_responsesinstance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L2050assert paused.result(timeout=3) is False
occ-001797tests/test_distributed_rollout.py:2053 · 快照test_admission_pause_acknowledges_workers_without_waiting_for_responsesinstance_candidateis_setunresolved_receiver_candidateassert not release.is_set()
occ-001798tests/test_distributed_rollout.py:2057 · 快照test_admission_pause_acknowledges_workers_without_waiting_for_responsesinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-001803tests/test_distributed_rollout.py:2079 · 快照test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run.fetchinstance_candidatesetunresolved_receiver_candidateentered.set()
occ-001805tests/test_distributed_rollout.py:2080 · 快照test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.run.fetchinstance_candidatewaitunresolved_receiver_candidateawait release.wait()
occ-001810tests/test_distributed_rollout.py:2095 · 快照test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.runinstance_candidatewaitunresolved_receiver_candidateawait entered.wait()
occ-001812tests/test_distributed_rollout.py:2097 · 快照test_queue_fetch_finishing_after_pause_preserves_group_without_new_generation.runinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-001815tests/test_distributed_rollout.py:2180 · 快照test_checkpoint_fork_restores_partial_ready_and_producer_without_parent_mutationinstance_candidatecloseunresolved_receiver_candidatefork.close()
occ-001816tests/test_distributed_rollout.py:2203 · 快照test_checkpoint_fork_restores_partial_ready_and_producer_without_parent_mutationinstance_candidatereleaseunresolved_receiver_candidatefork.release([assignment.lease])
occ-001817tests/test_distributed_rollout.py:2205 · 快照test_checkpoint_fork_restores_partial_ready_and_producer_without_parent_mutationinstance_candidatecloseunresolved_receiver_candidatefork.close()
occ-001818tests/test_distributed_rollout.py:2236 · 快照test_checkpoint_fork_restores_partial_ready_and_producer_without_parent_mutationinstance_candidatecloseunresolved_receiver_candidateresumed.close()
occ-001819tests/test_distributed_rollout.py:2274 · 快照test_automatic_empty_restore_reads_the_saved_dataset_offsetinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001820tests/test_distributed_rollout.py:2308 · 快照test_automatic_restart_before_first_checkpoint_recovers_the_same_queueinstance_candidatecloseunresolved_receiver_candidatereader.close()
occ-001821tests/test_distributed_rollout.py:2309 · 快照test_automatic_restart_before_first_checkpoint_recovers_the_same_queueinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001822tests/test_distributed_rollout.py:2323 · 快照test_automatic_restart_before_first_checkpoint_recovers_the_same_queueinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001828tests/test_fully_async_rollout.py:112 · 快照test_rollout_takes_target_groups_and_leaves_surplus_queuedinstance_candidateputunresolved_receiver_candidateworker.output_queue.put((gid, _make_group(gid)))
occ-001830tests/test_fully_async_rollout.py:132 · 快照test_get_completed_groups_limitinstance_candidateputunresolved_receiver_candidateworker.output_queue.put((gid, _make_group(gid)))
occ-001831tests/test_fully_async_rollout.py:153 · 快照test_dynamic_filter_drops_groups_and_refillsinstance_candidateputunresolved_receiver_candidateworker.output_queue.put((gid, group))
occ-001834tests/test_fully_async_rollout.py:219 · 快照test_done_callback_never_blocks_event_loop_threadinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L218pusher.start()
occ-001835tests/test_fully_async_rollout.py:220 · 快照test_done_callback_never_blocks_event_loop_threadinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L218pusher.join(timeout=30)
occ-001836tests/test_fully_async_rollout.py:222 · 快照test_done_callback_never_blocks_event_loop_threadinstance_candidateis_aliveinferred_receiver_candidate; threading.Thread @ L218assert not pusher.is_alive(), “done-callback blocked on a full output queue”
occ-001838tests/test_fully_async_rollout.py:241 · 快照test_loop_backpressure_stops_topping_up_when_queue_is_fullinstance_candidatestartunresolved_receiver_candidateworker.start()
occ-001840tests/test_fully_async_rollout.py:252 · 快照test_loop_backpressure_stops_topping_up_when_queue_is_fullinstance_candidatecloseunresolved_receiver_candidateworker.close()
occ-001846tests/test_fully_async_rollout.py:292 · 快照test_local_worker_lifecycle_is_scoped_to_source.<comprehension>instance_candidateis_aliveunresolved_receiver_candidateassert all(not worker.worker_thread.is_alive() for worker in workers)
occ-001852tests/test_glm52_6layer_deterministic_e2e.py:264 · 快照_train_argsinstance_candidatejoinunresolved_receiver_candidatereturn " “.join(groups)
occ-001857tests/test_glm52_6layer_deterministic_e2e.py:408 · 快照_runinstance_candidatewaitinferred_receiver_candidate; subprocess.Popen @ L402proc.wait()
occ-001858tests/test_glm52_6layer_deterministic_e2e.py:409 · 快照_runinstance_candidatejoinunresolved_receiver_candidatereturn proc.returncode, “".join(lines)
occ-001864tests/test_published_payload_retry.py:23 · 快照test_result_and_shelve_payloads_recover_at_the_storage_layerinstance_candidatereadunresolved_receiver_candidateheader = f.read(12)
occ-001865tests/test_published_payload_retry.py:25 · 快照test_result_and_shelve_payloads_recover_at_the_storage_layerinstance_candidatewriteunresolved_receiver_candidatef.write(bytes(12))
occ-001866tests/test_published_payload_retry.py:32 · 快照test_result_and_shelve_payloads_recover_at_the_storage_layer.restoreinstance_candidatewriteunresolved_receiver_candidatef.write(header)
occ-001868tests/test_published_payload_retry.py:37 · 快照test_result_and_shelve_payloads_recover_at_the_storage_layerinstance_candidatestartinferred_receiver_candidate; threading.Timer @ L36timer.start()
occ-001870tests/test_published_payload_retry.py:47 · 快照test_result_and_shelve_payloads_recover_at_the_storage_layerinstance_candidatejoininferred_receiver_candidate; threading.Timer @ L36timer.join()
occ-001874tests/test_qwen2.5_0.5B_opd_sglang.py:25 · 快照_get_gpu_splitinstance_candidatejoinunresolved_receiver_candidateall_gpus = os.environ.get(“CUDA_VISIBLE_DEVICES”, “,".join(str(i) for i in range(NUM_GPUS))).split(”,”)
occ-001877tests/test_qwen2.5_0.5B_opd_sglang.py:64 · 快照_launch_teacher_serverinstance_candidatepollinferred_receiver_candidate; subprocess.Popen @ L39if process.poll() is not None:
occ-001879tests/test_qwen2.5_0.5B_opd_sglang.py:75 · 快照_launch_teacher_serverinstance_candidatekillinferred_receiver_candidate; subprocess.Popen @ L39process.kill()
occ-001880tests/test_qwen2.5_0.5B_opd_sglang.py:84 · 快照executeinstance_candidatejoinunresolved_receiver_candidateos.environ[“CUDA_VISIBLE_DEVICES”] = “,".join(train_gpus)
occ-001881tests/test_qwen2.5_0.5B_opd_sglang.py:197 · 快照executeinstance_candidatekillunresolved_receiver_candidateteacher_process.kill()
occ-001882tests/test_qwen2.5_0.5B_opd_sglang.py:198 · 快照executeinstance_candidatewaitunresolved_receiver_candidateteacher_process.wait()
occ-001893tests/test_qwen2.5_0.5B_training_recovery.py:352 · 快照executeinstance_candidategetunresolved_receiver_candidatehttp.get(engine[“url”] + “/health”, timeout=2)
occ-001900tests/test_qwen3_4B_external_pd.py:120 · 快照_get_disaggregation_ib_deviceinstance_candidatejoinunresolved_receiver_candidatereturn “,".join(devices) if devices else None
occ-001901tests/test_qwen3_4B_external_pd.py:137 · 快照_get_gpu_splitinstance_candidatejoinunresolved_receiver_candidateall_gpus = os.environ.get(“CUDA_VISIBLE_DEVICES”, “,".join(str(i) for i in range(NUM_GPUS))).split(”,”)
occ-001903tests/test_qwen3_4B_external_pd.py:159 · 快照_launch_sglang_serverinstance_candidatejoinunresolved_receiver_candidateenv[“CUDA_VISIBLE_DEVICES”] = “,".join(gpus)
occ-001906tests/test_qwen3_4B_external_pd.py:201 · 快照_launch_sglang_serverinstance_candidatepollinferred_receiver_candidate; subprocess.Popen @ L190if process.poll() is not None:
occ-001908tests/test_qwen3_4B_external_pd.py:212 · 快照_launch_sglang_serverinstance_candidatekillinferred_receiver_candidate; subprocess.Popen @ L190process.kill()
occ-001910tests/test_qwen3_4B_external_pd.py:226 · 快照executeinstance_candidatejoinunresolved_receiver_candidateos.environ[“CUDA_VISIBLE_DEVICES”] = “,".join(train_gpus)
occ-001911tests/test_qwen3_4B_external_pd.py:319 · 快照executeinstance_candidatejoinunresolved_receiver_candidateexternal_args = “–rollout-external-engine-addrs " + " “.join(all_addrs) + " "
occ-001912tests/test_qwen3_4B_external_pd.py:374 · 快照executeinstance_candidatepollunresolved_receiver_candidateif p.poll() is None:
occ-001913tests/test_qwen3_4B_external_pd.py:375 · 快照executeinstance_candidatekillunresolved_receiver_candidatep.kill()
occ-001914tests/test_qwen3_4B_external_pd.py:376 · 快照executeinstance_candidatewaitunresolved_receiver_candidatep.wait()
occ-001922tests/test_rollout_manager_recovery.py:162 · 快照clusterinstance_candidateshutdownunresolved_receiver_candidatecluster.shutdown()
occ-001934tests/test_rollout_manager_recovery.py:387 · 快照test_driver_detach_releases_real_trainer_when_manager_cannot_pauseinstance_candidatecloseunresolved_receiver_candidatestartup.close(failed=True)
occ-001959tests/test_rollout_straw_transport.py:381 · 快照test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise.generateinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L376await second.wait()
occ-001961tests/test_rollout_straw_transport.py:392 · 快照test_synchronous_rollout_stores_during_generation_and_preserves_legacy_hook.exercise.packinstance_candidatecall_soon_threadsafeinferred_receiver_candidate; asyncio.AbstractEventLoop @ L377loop.call_soon_threadsafe(second.set)
occ-001966tests/test_rollout_straw_transport.py:465 · 快照test_manager_adapts_legacy_samples_and_validates_accepted_refsinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001967tests/test_rollout_straw_transport.py:597 · 快照test_durable_batch_replays_one_plan_and_rejects_mixed_ranksinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001968tests/test_rollout_straw_transport.py:709 · 快照test_straw_debug_archive_keys_lazy_tensors_gc_and_legacy_exportinstance_candidatereleaseunresolved_receiver_candidatearchive.release()
occ-001969tests/test_rollout_straw_transport.py:1058 · 快照test_disk_weight_updates_do_not_require_actor_return_values.<lambda>instance_candidateclearunresolved_receiver_candidatemonkeypatch.setattr(group, “release”, lambda: group._actor_handlers.clear())
occ-001970tests/test_rollout_straw_transport.py:1405 · 快照test_checkpoint_lock_covers_cleanup_and_releases_on_seal_failureinstance_candidatecloseunresolved_receiver_candidatecontroller.close()
occ-001977tests/test_rollout_straw_transport.py:1440 · 快照test_checkpoint_lock_released_when_controller_process_is_killedinstance_candidatereadlineunresolved_receiver_candidateassert process.stdout.readline() == b"ready\n”
occ-001978tests/test_rollout_straw_transport.py:1446 · 快照test_checkpoint_lock_released_when_controller_process_is_killedinstance_candidatekillinferred_receiver_candidate; subprocess.Popen @ L1418process.kill()
occ-001979tests/test_rollout_straw_transport.py:1447 · 快照test_checkpoint_lock_released_when_controller_process_is_killedinstance_candidatewaitinferred_receiver_candidate; subprocess.Popen @ L1418process.wait(timeout=30)
occ-001980tests/test_rollout_straw_transport.py:1448 · 快照test_checkpoint_lock_released_when_controller_process_is_killedinstance_candidatecloseunresolved_receiver_candidateprocess.stdin.close()
occ-001981tests/test_rollout_straw_transport.py:1449 · 快照test_checkpoint_lock_released_when_controller_process_is_killedinstance_candidatecloseunresolved_receiver_candidateprocess.stdout.close()
occ-001982tests/test_rollout_straw_transport.py:1450 · 快照test_checkpoint_lock_released_when_controller_process_is_killedinstance_candidatecloseunresolved_receiver_candidateprocess.stderr.close()
occ-002010tests/test_server_control.py:94 · 快照test_boundary_health_check_bypasses_grace_and_cleans_dead_actorinstance_candidatestartunresolved_receiver_candidatemonitor.start()
occ-002011tests/test_server_control.py:100 · 快照test_boundary_health_check_bypasses_grace_and_cleans_dead_actorinstance_candidatestopunresolved_receiver_candidatemonitor.stop()
occ-002028tests/test_server_control.py:239 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serveinstance_candidatereaduntilunresolved_receiver_candidateheaders = await reader.readuntil(b”\r\n\r\n”)
occ-002030tests/test_server_control.py:248 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serveinstance_candidatereadexactlyunresolved_receiver_candidatebody = await reader.readexactly(length)
occ-002033tests/test_server_control.py:251 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serveinstance_candidatewriteunresolved_receiver_candidatewriter.write(b"HTTP/1.1 200 OK\r\nContent-Length: " + str(len(body)).encode() + b”\r\n\r\n” + body)
occ-002035tests/test_server_control.py:252 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serveinstance_candidatedrainunresolved_receiver_candidateawait writer.drain()
occ-002037tests/test_server_control.py:257 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serveinstance_candidatecloseunresolved_receiver_candidatewriter.close()
occ-002039tests/test_server_control.py:258 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.check.serveinstance_candidatewait_closedunresolved_receiver_candidateawait writer.wait_closed()
occ-002050tests/test_server_control.py:279 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.checkinstance_candidatecloseunresolved_receiver_candidateserver.close()
occ-002052tests/test_server_control.py:280 · 快照test_http_transport_preserves_streams_timeouts_and_connection_budget.checkinstance_candidatewait_closedunresolved_receiver_candidateawait server.wait_closed()
occ-002065tests/test_straw_fully_async_recovery.py:49 · 快照_generate_with_interruptinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L49await asyncio.Event().wait()
occ-002068tests/test_straw_fully_async_recovery.py:52 · 快照_generate_with_interruptinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L52await asyncio.Event().wait()
occ-002072tests/test_straw_fully_async_recovery.py:87 · 快照_reward_onceinstance_candidategetunresolved_receiver_candidateassert sample.metadata.get(“reward_calls”, 0) == 0, “A completed sample was scored twice”
occ-002074tests/test_straw_fully_async_recovery.py:133 · 快照_run_jobinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L132thread.start()
occ-002076tests/test_straw_fully_async_recovery.py:158 · 快照_run_jobinstance_candidatewaitinferred_receiver_candidate; threading.Event @ L158threading.Event().wait()
occ-002078tests/test_straw_fully_async_recovery.py:197 · 快照_run_jobinstance_candidatecloseunresolved_receiver_candidatesource.close()
occ-002079tests/test_straw_fully_async_recovery.py:199 · 快照_run_jobinstance_candidateshutdownunresolved_receiver_candidatecluster.shutdown()
occ-002080tests/test_straw_fully_async_recovery.py:204 · 快照_kill_jobinstance_candidatepollunresolved_receiver_candidateif process.poll() is not None:
occ-002081tests/test_straw_fully_async_recovery.py:225 · 快照_kill_jobinstance_candidatekillunresolved_receiver_candidatechild.kill()
occ-002082tests/test_straw_fully_async_recovery.py:228 · 快照_kill_jobinstance_candidatewaitunresolved_receiver_candidateprocess.wait(timeout=20)
occ-002083tests/test_straw_fully_async_recovery.py:234 · 快照_kill_jobinstance_candidateis_runningunresolved_receiver_candidateif child.is_running() and child.status() != psutil.STATUS_ZOMBIE:
occ-002087tests/test_straw_fully_async_recovery.py:268 · 快照test_fully_async_sigkill_and_restart_preserves_results_and_prefixesinstance_candidatepollinferred_receiver_candidate; subprocess.Popen @ L257assert process.poll() is None, log_path.read_text()[-12000:]
occ-002090tests/test_straw_fully_async_recovery.py:278 · 快照test_fully_async_sigkill_and_restart_preserves_results_and_prefixesinstance_candidatewaitinferred_receiver_candidate; subprocess.Popen @ L257assert process.wait(timeout=180) == 0, log_path.read_text()[-12000:]
occ-002097tests/test_straw_r3.py:150 · 快照test_cancelled_straw_publication_drains_before_releasing_capacity.delayed_writeinstance_candidatesetunresolved_receiver_candidateentered.set()
occ-002098tests/test_straw_r3.py:151 · 快照test_cancelled_straw_publication_drains_before_releasing_capacity.delayed_writeinstance_candidatewaitunresolved_receiver_candidateif not release.wait(5):
occ-002103tests/test_straw_r3.py:164 · 快照test_cancelled_straw_publication_drains_before_releasing_capacity.runinstance_candidatecancelinferred_receiver_candidate; asyncio.Task @ L160first.cancel()
occ-002107tests/test_straw_r3.py:168 · 快照test_cancelled_straw_publication_drains_before_releasing_capacity.runinstance_candidatecancelinferred_receiver_candidate; asyncio.Task @ L160first.cancel() # A second shutdown signal must not release the writer early.
occ-002110tests/test_straw_r3.py:170 · 快照test_cancelled_straw_publication_drains_before_releasing_capacity.runinstance_candidatedoneinferred_receiver_candidate; asyncio.Task @ L160assert not first.done()
occ-002111tests/test_straw_r3.py:173 · 快照test_cancelled_straw_publication_drains_before_releasing_capacity.runinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-002116tests/test_straw_r3.py:216 · 快照test_lazy_prefetch_reloads_between_forward_and_backwardinstance_candidatecloseunresolved_receiver_candidateprefetcher.close()
occ-002119tests/test_streaming_rollout.py:100 · 快照test_merge_stream_chunks.decodeinstance_candidatejoinunresolved_receiver_candidatereturn “".join(f”<{token_id}>” for token_id in token_ids)
occ-002120tests/test_streaming_rollout.py:122 · 快照_generation_state.<lambda>instance_candidatejoinunresolved_receiver_candidatedecode=lambda token_ids, skip_special_tokens=False: “".join(f”<{token_id}>” for token_id in token_ids)
occ-002127tests/test_streaming_rollout.py:242 · 快照test_generate_streaming_preserves_metadata_across_stream_intervalsinstance_candidatejoinunresolved_receiver_candidate“".join(f”<{token_id}>” for token_id in token_slice),
occ-002140tests/test_streaming_rollout.py:368 · 快照test_stream_cancellation_closes_request_and_keeps_prefix.linesinstance_candidatesetinferred_receiver_candidate; asyncio.Event @ L352first_chunk_seen.set()
occ-002143tests/test_streaming_rollout.py:369 · 快照test_stream_cancellation_closes_request_and_keeps_prefix.linesinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L369await asyncio.Event().wait()
occ-002145tests/test_streaming_rollout.py:376 · 快照test_stream_cancellation_closes_request_and_keeps_prefix.server_generateinstance_candidatesetinferred_receiver_candidate; asyncio.Event @ L354server_started.set()
occ-002147tests/test_streaming_rollout.py:377 · 快照test_stream_cancellation_closes_request_and_keeps_prefix.server_generateinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L355await server_released.wait()
occ-002150tests/test_streaming_rollout.py:386 · 快照test_stream_cancellation_closes_request_and_keeps_prefix.abort_serversinstance_candidatesetinferred_receiver_candidate; asyncio.Event @ L355server_released.set()
occ-002156tests/test_streaming_rollout.py:401 · 快照test_stream_cancellation_closes_request_and_keeps_prefix.exerciseinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L352await asyncio.gather(first_chunk_seen.wait(), server_started.wait())
occ-002157tests/test_streaming_rollout.py:401 · 快照test_stream_cancellation_closes_request_and_keeps_prefix.exerciseinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L354await asyncio.gather(first_chunk_seen.wait(), server_started.wait())
occ-002162tests/test_streaming_rollout.py:410 · 快照test_stream_cancellation_closes_request_and_keeps_prefixinstance_candidateis_setinferred_receiver_candidate; asyncio.Event @ L353assert request_closed.is_set()
occ-002165tests/test_streaming_rollout.py:420 · 快照test_unrelated_stream_cancellation_propagates.linesinstance_candidatesetinferred_receiver_candidate; asyncio.Event @ L416request_started.set()
occ-002168tests/test_streaming_rollout.py:421 · 快照test_unrelated_stream_cancellation_propagates.linesinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L421await asyncio.Event().wait()
occ-002173tests/test_streaming_rollout.py:435 · 快照test_unrelated_stream_cancellation_propagates.exerciseinstance_candidatewaitinferred_receiver_candidate; asyncio.Event @ L416await request_started.wait()
occ-002174tests/test_streaming_rollout.py:437 · 快照test_unrelated_stream_cancellation_propagates.exerciseinstance_candidatecancelinferred_receiver_candidate; asyncio.Task @ L428task.cancel()
occ-002194tests/test_streaming_rollout.py:555 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise.generateinstance_candidatesetunresolved_receiver_candidatefirst_batch.set()
occ-002195tests/test_streaming_rollout.py:557 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise.generateinstance_candidatesetunresolved_receiver_candidateall_started.set()
occ-002197tests/test_streaming_rollout.py:558 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise.generateinstance_candidatewaitunresolved_receiver_candidateawait finish.wait()
occ-002201tests/test_streaming_rollout.py:573 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exerciseinstance_candidatewaitunresolved_receiver_candidateawait asyncio.wait_for(first_batch.wait(), 1)
occ-002202tests/test_streaming_rollout.py:576 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exercise.<comprehension>instance_candidatedoneunresolved_receiver_candidateassert not any(task.done() for task in tasks)
occ-002203tests/test_streaming_rollout.py:577 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exerciseinstance_candidatecancelunresolved_receiver_candidatetasks[70].cancel()
occ-002208tests/test_streaming_rollout.py:581 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exerciseinstance_candidatewaitunresolved_receiver_candidateawait asyncio.wait_for(all_started.wait(), 1)
occ-002209tests/test_streaming_rollout.py:584 · 快照test_generation_pacing_preserves_concurrency_cancellation_and_reuse.exerciseinstance_candidatesetunresolved_receiver_candidatefinish.set()
occ-002218tests/test_streaming_rollout.py:601 · 快照test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise.wait_for_releaseinstance_candidatesetunresolved_receiver_candidatequeued.set()
occ-002220tests/test_streaming_rollout.py:602 · 快照test_abort_while_waiting_for_generation_pacer_does_not_start_request.exercise.wait_for_releaseinstance_candidatewaitunresolved_receiver_candidateawait release.wait()
occ-002225tests/test_streaming_rollout.py:612 · 快照test_abort_while_waiting_for_generation_pacer_does_not_start_request.exerciseinstance_candidatewaitunresolved_receiver_candidateawait queued.wait()
occ-002226tests/test_streaming_rollout.py:614 · 快照test_abort_while_waiting_for_generation_pacer_does_not_start_request.exerciseinstance_candidatesetunresolved_receiver_candidaterelease.set()
occ-002231tests/test_training_recovery.py:310 · 快照test_recovery_e2e_contacts_dashboard_without_proxy.Dashboard.do_GETinstance_candidatewriteunresolved_receiver_candidateself.wfile.write(body)
occ-002234tests/test_training_recovery.py:340 · 快照test_recovery_e2e_contacts_dashboard_without_proxyinstance_candidatestartinferred_receiver_candidate; threading.Thread @ L339thread.start()
occ-002235tests/test_training_recovery.py:345 · 快照test_recovery_e2e_contacts_dashboard_without_proxyinstance_candidateshutdownunresolved_receiver_candidateserver.shutdown()
occ-002236tests/test_training_recovery.py:346 · 快照test_recovery_e2e_contacts_dashboard_without_proxyinstance_candidatejoininferred_receiver_candidate; threading.Thread @ L339thread.join(timeout=5)
occ-002237tests/test_training_recovery.py:349 · 快照test_recovery_e2e_contacts_dashboard_without_proxy.<comprehension>instance_candidategetunresolved_receiver_candidateassert all(not env.get(name) for env in started for name in proxies)
occ-002238tests/test_training_recovery.py:513 · 快照test_source_snapshot_restores_cursor_and_bufferinstance_candidateclearunresolved_receiver_candidatesource.buffer.clear()
occ-002239tests/test_training_recovery.py:648 · 快照test_failed_attempt_releases_trainers_despite_manager_failureinstance_candidatecloseunresolved_receiver_candidatestartup.close(failed=True)
occ-002240tests/test_training_recovery.py:673 · 快照test_successful_attempt_cleans_both_owners_after_dispose_errorinstance_candidatecloseunresolved_receiver_candidatestartup.close(failed=False)
occ-002241tests/test_training_recovery.py:715 · 快照test_training_resume_keeps_checkpoint_and_attempt_configuration_separateinstance_candidateapplyunresolved_receiver_candidateresolved = resume.apply(args)
occ-002246tests/training_recovery_test_helpers.py:38 · 快照_session_snapshotinstance_candidategetunresolved_receiver_candidatefor routes in data.get(“rollout_routed_experts”, []):
occ-002253tools/convert_hf_to_fp8.py:181 · 快照convert_fp8instance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L178future = executor.submit(
occ-002254tools/convert_hf_to_fp8.py:187 · 快照convert_fp8instance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L181future.result()
occ-002259tools/convert_hf_to_int4_direct.py:227 · 快照convert_int4instance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L224future = executor.submit(
occ-002260tools/convert_hf_to_int4_direct.py:240 · 快照convert_int4instance_candidateresultinferred_receiver_candidate; concurrent.futures.Future @ L227future.result()
occ-002266tools/convert_torch_dist_to_hf_parallel.py:137 · 快照WrappedStorageReader._parallel_preload_files.read_fileinstance_candidatereadunresolved_receiver_candidatedata = stream.read()
occ-002267tools/convert_torch_dist_to_hf_parallel.py:140 · 快照WrappedStorageReader._parallel_preload_files.read_fileinstance_candidatereadunresolved_receiver_candidatedata = stream.read()
occ-002269tools/convert_torch_dist_to_hf_parallel.py:149 · 快照WrappedStorageReader._parallel_preload_files.<comprehension>instance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L147executor.submit(read_file, rel_path, full_path, ops): rel_path
occ-002271tools/convert_torch_dist_to_hf_parallel.py:155 · 快照WrappedStorageReader._parallel_preload_filesinstance_candidateresultunresolved_receiver_candidateresult = future.result()
occ-002274tools/convert_torch_dist_to_hf_parallel.py:297 · 快照save_tensors.<comprehension>instance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L296futures = {executor.submit(process_and_collect, (name, param)): name for name, param in param_list}
occ-002276tools/convert_torch_dist_to_hf_parallel.py:299 · 快照save_tensorsinstance_candidateresultunresolved_receiver_candidateconverted = future.result()
occ-002278tools/convert_torch_dist_to_hf_parallel.py:337 · 快照save_tensors.<comprehension>instance_candidatesubmitinferred_receiver_candidate; concurrent.futures.ThreadPoolExecutor @ L336futures = [executor.submit(save_file, i, tensors) for i, tensors in enumerate(modeltensors)]
occ-002280tools/convert_torch_dist_to_hf_parallel.py:339 · 快照save_tensorsinstance_candidateresultunresolved_receiver_candidatefilename, elapsed = future.result()
occ-002282tools/convert_torch_dist_to_hf_parallel.py:512 · 快照<module>instance_candidatePoolinferred_receiver_candidate; multiprocessing.context.BaseContext @ L511with ctx.Pool(num_workers) as pool:
occ-002283tools/convert_torch_dist_to_hf_parallel.py:513 · 快照<module>instance_candidatestarmapinferred_receiver_candidate; multiprocessing.Pool @ L512results = pool.starmap(

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