async def atom_async_get(entries_already_processed, total_expected_records):
    response_list = []
    loop = asyncio.get_event_loop()
    requests_at_once = MAX_REQUESTS_AT_ONCE
    if ((total_expected_records - entries_already_processed) < (MAX_REQUESTS_AT_ONCE * MAX_ENTRIES)):
        requests_at_once = (math.ceil(((total_expected_records - entries_already_processed) / MAX_ENTRIES)) + 1)
    futures = [loop.run_in_executor(None, get_with_exception_hand, ((base_url + '&start=') + str((entries_already_processed + (start_offset * MAX_ENTRIES)))), (total_expected_records > (entries_already_processed + (start_offset * MAX_ENTRIES)))) for start_offset in range(requests_at_once)]
    for response in (await asyncio.gather(*futures)):
        response_list.append(response.text)
        pass
    return response_list
async def atom_async_get(entries_already_processed, total_expected_records):
    response_list = []
    loop = asyncio.get_event_loop()
    requests_at_once = MAX_REQUESTS_AT_ONCE
    if ((total_expected_records - entries_already_processed) < (MAX_REQUESTS_AT_ONCE * MAX_ENTRIES)):
        requests_at_once = (math.ceil(((total_expected_records - entries_already_processed) / MAX_ENTRIES)) + 1)
    futures = [loop.run_in_executor(None, get_with_exception_hand, ((base_url + '&start=') + str((entries_already_processed + (start_offset * MAX_ENTRIES)))), (total_expected_records > (entries_already_processed + (start_offset * MAX_ENTRIES)))) for start_offset in range(requests_at_once)]
    for response in (await asyncio.gather(*futures)):
        response_list.append(response.text)
        pass
    return response_list