@@ -393,7 +393,7 @@ def test_prefill_logic(self):
393393 mock_model_output = MagicMock ()
394394 mock_model_output .req_id_to_index = {"test_req" : 0 }
395395 mock_model_output .sampled_token_ids = [[1 ]]
396- self .mock_prefill_engine .execute_model_with_error_logging .return_value = mock_model_output
396+ self .mock_prefill_engine .model_executor . execute_model .return_value = mock_model_output
397397
398398 # Mock request
399399 mock_request = MagicMock ()
@@ -408,7 +408,7 @@ def stop_loop(*args, **kwargs):
408408
409409 orchestrator ._prefill (0 )
410410
411- self .mock_prefill_engine .execute_model_with_error_logging .assert_called_once (
411+ self .mock_prefill_engine .model_executor . execute_model .assert_called_once (
412412 )
413413 self .assertTrue (orchestrator ._transfer_backlogs [0 ].qsize () > 0 )
414414
@@ -477,7 +477,7 @@ def test_decode_logic(self):
477477
478478 # Mock model output
479479 mock_model_output = MagicMock ()
480- self .mock_decode_engine .execute_model_with_error_logging .return_value = mock_model_output
480+ self .mock_decode_engine .model_executor . execute_model .return_value = mock_model_output
481481
482482 # Mock the side effect of update_from_output to stop the loop
483483 def stop_loop (* args , ** kwargs ):
@@ -488,7 +488,7 @@ def stop_loop(*args, **kwargs):
488488
489489 orchestrator ._decode (0 )
490490
491- self .mock_decode_engine .execute_model_with_error_logging .assert_called_once (
491+ self .mock_decode_engine .model_executor . execute_model .assert_called_once (
492492 )
493493 self .mock_output_queue .put_nowait .assert_called_once ()
494494
0 commit comments