"""Test for multiprocessing_request."""
import concurrency.multiprocess_requests as mp_requests

# import concurrency.mapper as mapper


def test_multiprocess_requests(
        mocker, test_full_request_list, test_multiprocess_param,
        test_session_id, test_label_id):
    """Test that processes are created."""
    # mock_pool = mocker.patch.object(mapper, 'ProcessPool')
    mock_mapper = mocker.patch.object(mp_requests, 'map_processes',
                                      return_value=([], [], [], []))

    mp_requests.config.NUM_THREADS = 5

    file_name = 'file.txt'

    mp_requests.multiprocess_requests(
        test_label_id, test_full_request_list, test_session_id, file_name)

    # assert mock_pool.call_count == 1
    assert mock_mapper.call_count == 1
    assert mock_mapper.calledWith(test_multiprocess_param)
    # assert mock_pool.return_value.join.call_count == 1
    # assert mock_pool.return_value.close.call_count == 1