Skip to content

[Fix] Update flush cache worker broadcast - #2071

Open
matrix72c wants to merge 1 commit into
InternLM:mainfrom
matrix72c:fix/flush-cache-broadcast
Open

[Fix] Update flush cache worker broadcast#2071
matrix72c wants to merge 1 commit into
InternLM:mainfrom
matrix72c:fix/flush-cache-broadcast

Conversation

@matrix72c

Copy link
Copy Markdown
Contributor

Summary

  • update RolloutController.flush_cache() to use the lifecycle-aware _broadcast_to_workers helper after the worker broadcast refactor
  • add a regression test covering the active-worker flush-cache dispatch

Root cause

The upstream flush-cache feature added a call to _broadcast_to_active_workers, while the later controller refactor renamed that helper to _broadcast_to_workers and missed this caller.

Test plan

  • PYTEST_DISABLE_PLUGIN_AUTOLOAD=1 PYTHONPATH=.../xtuner sandbox_rl/.venv/bin/python -m pytest -q tests/rl/test_rollout_logic.py (61 passed)

@matrix72c
matrix72c force-pushed the fix/flush-cache-broadcast branch from 6b0c75d to 1fffeb4 Compare September 7, 2026 03:52
@matrix72c matrix72c changed the title fix(rl): update flush cache worker broadcast [Fix] Update flush cache worker broadcast Sep 7, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant