relax pin on httpx and respx, switch to anyio from pytest-asyncio, fix all warnings

To fix the 3.10 warnings we relax the pins on httpx and respx and tried
to relax the pin on pytest-asyncio but ultimately moved to anyio.

We switch to anyio from pytest-asyncio because the latest version of
pytest-asyncio kept throwing errors and anyio is already a dependency of httpx.

Warnings popped up due to not using a context manager for open(),
typically in json.load(open(filename)), so these were changed.

Warnings also popped up due to non-async cli tests using
pytest.mark.anyio, so these were removed.

Author: jreiberkyle

setup.py

@@ -26,14 +26,14 @@
 install_requires = [
     'click>=8.0.0',
     'geojson',
-    'httpx==0.23.0',
+    'httpx>=0.23.0',
     'jsonschema',
     'pyjwt>=2.1',
     'tqdm>=4.56',
     'typing-extensions',
 ]
 
-test_requires = ['pytest', 'pytest-asyncio==0.16', 'pytest-cov', 'respx==0.19']
+test_requires = ['pytest', 'anyio', 'pytest-cov', 'respx>=0.20']
 
 lint_requires = ['flake8', 'mypy', 'yapf']
 

tests/conftest.py

@@ -50,7 +50,9 @@ def get_test_file_json():
 
     def func(filename):
         file_path = _test_data_path / filename
-        return json.load(open(file_path, 'r'))
+        with open(file_path, 'r') as f:
+            res = json.load(f)
+        return res
 
     return func
 
@@ -147,3 +149,8 @@ def multipolygon_geom_geojson():
           [37.791595458984375, 14.945448293647944],
           [37.791595458984375, 14.84923123791421]]]]
     }  # yapf: disable
+
+
+@pytest.fixture
+def anyio_backend():
+    return 'asyncio'

tests/integration/conftest.py

@@ -28,7 +28,7 @@ def test_disable_limiter(monkeypatch):
 
 
 @pytest.fixture
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def session():
     async with planet.Session() as ps:
         yield ps

tests/integration/test_data_api.py

@@ -71,7 +71,7 @@ def search_response(item_descriptions):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_search_basic(item_descriptions, search_response, session):
 
     quick_search_url = f'{TEST_URL}/quick-search'
@@ -105,7 +105,7 @@ async def test_search_basic(item_descriptions, search_response, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_search_name(item_descriptions, search_response, session):
 
     quick_search_url = f'{TEST_URL}/quick-search'
@@ -141,7 +141,7 @@ async def test_search_name(item_descriptions, search_response, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_search_filter(item_descriptions,
                              search_filter,
                              search_response,
@@ -178,7 +178,7 @@ async def test_search_filter(item_descriptions,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_search_sort(item_descriptions,
                            search_filter,
                            search_response,
@@ -201,7 +201,7 @@ async def test_search_sort(item_descriptions,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_search_limit(item_descriptions,
                             search_filter,
                             search_response,
@@ -226,7 +226,7 @@ async def test_search_limit(item_descriptions,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_create_search_basic(search_filter, session):
 
     page_response = {
@@ -262,7 +262,7 @@ async def test_create_search_basic(search_filter, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_create_search_email(search_filter, session):
 
     page_response = {
@@ -300,7 +300,7 @@ async def test_create_search_email(search_filter, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_get_search_success(search_id, search_result, session):
     get_url = f'{TEST_SEARCHES_URL}/{search_id}'
     mock_resp = httpx.Response(HTTPStatus.OK, json=search_result)
@@ -311,7 +311,7 @@ async def test_get_search_success(search_id, search_result, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_get_search_id_doesnt_exist(search_id, session):
     get_url = f'{TEST_SEARCHES_URL}/{search_id}'
 
@@ -328,7 +328,7 @@ async def test_get_search_id_doesnt_exist(search_id, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_update_search_basic(search_filter, session):
 
     page_response = {
@@ -367,7 +367,7 @@ async def test_update_search_basic(search_filter, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("limit, expected_list_length", [(None, 4), (3, 3)])
 async def test_list_searches_success(limit,
                                      expected_list_length,
@@ -386,7 +386,7 @@ async def test_list_searches_success(limit,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("sort, rel_url",
                          [(LIST_SORT_DEFAULT, ''),
                           ('created asc', '?_sort=created+asc')])
@@ -402,7 +402,7 @@ async def test_list_searches_sort(sort, rel_url, search_result, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("search_type, rel_url",
                          [(LIST_SEARCH_TYPE_DEFAULT, ''),
                           ('saved', '?search_type=saved')])
@@ -421,7 +421,7 @@ async def test_list_searches_searchtype(search_type,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize(
     "sort, search_type, expectation",
     [('DOESNOTEXIST', 'ANY', pytest.raises(exceptions.ClientError)),
@@ -442,7 +442,7 @@ async def test_list_searches_args_do_not_match(sort,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("retcode, expectation",
                          [(204, does_not_raise()),
                           (404, pytest.raises(exceptions.APIError))])
@@ -459,7 +459,7 @@ async def test_delete_search(retcode, expectation, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("search_id, valid", [(VALID_SEARCH_ID, True),
                                               ('invalid', False)])
 @pytest.mark.parametrize("limit, expected_count", [(None, 3), (2, 2)])
@@ -500,7 +500,7 @@ async def test_run_search_basic(item_descriptions,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("sort, rel_url, valid",
                          [(SEARCH_SORT_DEFAULT, '', True),
                           ('acquired asc', '?_sort=acquired+asc', True),
@@ -537,7 +537,7 @@ async def test_run_search_sort(item_descriptions,
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_run_search_doesnotexist(session):
     route = respx.get(f'{TEST_SEARCHES_URL}/{VALID_SEARCH_ID}/results')
     route.return_value = httpx.Response(404)
@@ -550,7 +550,7 @@ async def test_run_search_doesnotexist(session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_get_stats_success(search_filter, session):
 
     page_response = {
@@ -584,7 +584,7 @@ async def test_get_stats_success(search_filter, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_get_stats_invalid_interval(search_filter, session):
     cl = DataClient(session, base_url=TEST_URL)
 
@@ -593,7 +593,7 @@ async def test_get_stats_invalid_interval(search_filter, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_list_item_assets_success(session):
     item_type_id = 'PSScene'
     item_id = '20221003_002705_38_2461'
@@ -637,7 +637,7 @@ async def test_list_item_assets_success(session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_list_item_assets_missing(session):
     item_type_id = 'PSScene'
     item_id = '20221003_002705_38_2461xx'
@@ -653,7 +653,7 @@ async def test_list_item_assets_missing(session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("asset_type_id, expectation",
                          [('basic_udm2', does_not_raise()),
                           ('invalid', pytest.raises(exceptions.ClientError))])
@@ -703,7 +703,7 @@ async def test_get_asset(asset_type_id, expectation, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("status, expectation", [('inactive', True),
                                                  ('active', False)])
 async def test_activate_asset_success(status, expectation, session):
@@ -732,7 +732,7 @@ async def test_activate_asset_success(status, expectation, session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_activate_asset_invalid_asset(session):
     cl = DataClient(session, base_url=TEST_URL)
 
@@ -741,7 +741,7 @@ async def test_activate_asset_invalid_asset(session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_wait_asset_success(session):
     asset_url = f'{TEST_URL}/asset'
 
@@ -774,7 +774,7 @@ async def test_wait_asset_success(session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 async def test_wait_asset_max_attempts(session):
     asset_url = f'{TEST_URL}/asset'
 
@@ -803,7 +803,7 @@ async def test_wait_asset_max_attempts(session):
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("exists, overwrite",
                          [(False, False), (True, False), (True, True),
                           (False, True)])
@@ -870,7 +870,7 @@ async def _stream_img():
 
 
 @respx.mock
-@pytest.mark.asyncio
+@pytest.mark.anyio
 @pytest.mark.parametrize("hashes_match, md5_entry, expectation",
                          [(True, True, does_not_raise()),
                           (False, True, pytest.raises(exceptions.ClientError)),