def METHOD_NAME(notify_api, mocker):
    mocker.patch("app.celery.research_mode_tasks.file_exists", return_value=False)
    mocker.patch("app.celery.research_mode_tasks.s3upload")
    mock_task = mocker.patch("app.celery.research_mode_tasks.process_sns_results")
    with set_config_values(notify_api, {"NOTIFY_ENVIRONMENT": "development"}):
        some_ref = str(uuid.uuid4())
        create_fake_letter_response_file(some_ref)
        mock_task.apply_async.assert_called_once_with(ANY, queue=QueueNames.RESEARCH_MODE)
        message = json.loads(mock_task.apply_async.call_args[0][0][0])
        assert message["MessageId"] == some_ref