| """静态核对: 流水路径与同步路径在关键行为上是否一致。""" |
| P = "/home/haojinw2/rose-bundle-new/verl/recipe/rose/rose_agent_loop.py" |
| s = open(P).read() |
| sync = s[s.index("async def _run_sync"): s.index(" # ==================================================================")] |
| pipe = s[s.index("async def _run_pipelined"):] |
|
|
| checks = [ |
| ("teacher budget 上限受 response_length 约束", "response_length - len(prefix_ids)" in pipe), |
| ("跨词表 splice 走同一函数", "self._splice(" in pipe and "self._splice(" in sync), |
| ("train_prefix 分支", "self.train_prefix" in pipe and "self.train_prefix" in sync), |
| ("on_early_finish=drop 生效", '"drop"' in pipe or 'item["drop"]' in pipe), |
| ("resample 逻辑", "resample" in pipe), |
| ("response 截断到 response_length", "[: self.response_length]" in pipe), |
| ("seam_shift 上报", "seam_shift" in pipe), |
| ] |
| for name, ok in checks: |
| print(f" [{'OK' if ok else '缺'}] {name}") |
|
|
| |
| print("\n同步版 drop 处理:", "skip = early_finish and self.on_early_finish" in sync) |
| print("流水版 drop 处理: tprompt 置 None ->", 'if not drop and prefix_ids:' in s) |
|
|
