@@ -239,7 +239,7 @@ def test_processor_processing_organisations_successful(
239239) -> None :
240240 expected_call_count = 2 # ODS Terminology API + APIM UUID lookup
241241 date = datetime .now ().strftime ("%Y-%m-%d" )
242- load_data_mock = mocker .patch ("pipeline.processor.load_data " )
242+ load_data_mock = mocker .patch ("pipeline.processor.send_messages_to_queue " )
243243 assert processor (date ) is None
244244 assert requests_mock .call_count == expected_call_count
245245
@@ -261,7 +261,7 @@ def test_processor_processing_organisations_successful(
261261 assert (
262262 requests_mock .request_history [1 ] == mock_responses .apim_org_abc123 .last_request
263263 )
264- # Assert load_data call
264+ # Assert send_messages_to_queue call
265265 load_data_mock .assert_called_once ()
266266 data_to_load = [json .loads (entry ) for entry in load_data_mock .call_args [0 ][0 ]]
267267 # Check the data struct
@@ -454,7 +454,7 @@ def test_processor_continue_on_validation_failure(
454454
455455 date = datetime .now ().strftime ("%Y-%m-%d" )
456456
457- load_data_mock = mocker .patch ("pipeline.processor.load_data " )
457+ load_data_mock = mocker .patch ("pipeline.processor.send_messages_to_queue " )
458458 assert processor (date ) is None
459459
460460 assert requests_mock .call_count == expected_call_count
@@ -483,7 +483,7 @@ def test_processor_continue_on_validation_failure(
483483 )
484484 assert requests_mock .request_history [2 ] == apim_efg456_mock .last_request
485485
486- # Assert load_data call - only EFG456 should be loaded
486+ # Assert send_messages_to_queue call - only EFG456 should be loaded
487487 load_data_mock .assert_called_once ()
488488 data_to_load = [json .loads (entry ) for entry in load_data_mock .call_args [0 ][0 ]]
489489
0 commit comments