We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e2d783d commit c51b931Copy full SHA for c51b931
1 file changed
tests/backends/skyrl_train/distributed/test_megatron_correctness.py
@@ -163,7 +163,7 @@ async def test_non_colocated_pause_before_broadcast(self):
163
dispatch._inference_engine_client = AsyncMock()
164
dispatch._inference_engine_client.pause_generation = AsyncMock(side_effect=lambda: call_order.append("pause"))
165
dispatch._inference_engine_client.resume_generation = AsyncMock(side_effect=lambda: call_order.append("resume"))
166
- dispatch._broadcast_to_inference_engines = MagicMock(side_effect=lambda _: call_order.append("broadcast"))
+ dispatch._broadcast_to_inference_engines = MagicMock(side_effect=lambda *args, **kwargs: call_order.append("broadcast"))
167
dispatch._prepare_for_weight_sync = MagicMock()
168
dispatch._finish_weight_sync = MagicMock()
169
0 commit comments