MOD: Deprecate Python 3.7 in the client library

Author: nmacholl

.github/workflows/test.yml

@@ -10,7 +10,7 @@ jobs:
       fail-fast: false
       matrix:
         os: [ubuntu-latest, macos-latest, windows-latest]
-        python-version: ["3.7", "3.8", "3.9", "3.10", "3.11"]
+        python-version: ["3.8", "3.9", "3.10", "3.11"]
     name: build - Python ${{ matrix.python-version }} (${{ matrix.os }})
     runs-on: ${{ matrix.os }}
 

CHANGELOG.md

@@ -1,5 +1,13 @@
 # Changelog
 
+## 0.14.0 - TBD
+- Upgraded `aiohttp` to 3.8.3
+- Upgraded `numpy` to to 1.23.5
+- Upgraded `pandas` to to 1.5.3
+- Upgraded `requests` to to 2.28.1
+- Upgraded `zstandard` to to 0.21.0
+- Removed support for Python 3.7
+
 ## 0.13.0 - 2023-06-02
 - Added support for `statistics` schema
 - Added batch download support data files (`condition.json` and `symbology.json`)

README.md

@@ -1,7 +1,7 @@
 # databento-python
 
 [![test](https://github.com/databento/databento-python/actions/workflows/test.yml/badge.svg?branch=dev)](https://github.com/databento/databento-python/actions/workflows/test.yml)
-![python](https://img.shields.io/badge/python-3.7+-blue.svg)
+![python](https://img.shields.io/badge/python-3.8+-blue.svg)
 [![pypi-version](https://img.shields.io/pypi/v/databento)](https://pypi.org/project/databento)
 [![license](https://img.shields.io/github/license/databento/databento-python?color=blue)](./LICENSE)
 [![code-style: black](https://img.shields.io/badge/code%20style-black-000000.svg)](https://github.com/psf/black)
@@ -27,15 +27,15 @@ You can find our full client API reference on the [Historical Reference](https:/
 [Examples](https://docs.databento.com/examples?historical=python&live=python) section for various tutorials and code samples.
 
 ## Requirements
-The library is fully compatible with the latest distribution of Anaconda 3.7 and above.
+The library is fully compatible with the latest distribution of Anaconda 3.8 and above.
 The minimum dependencies as found in the `pyproject.toml` are also listed below:
-- python = "^3.7"
-- aiohttp = "^3.7.2"
+- python = "^3.8"
+- aiohttp = "^3.8.3"
 - databento-dbn = "0.6.1"
-- numpy= ">=1.17.0"
-- pandas = ">=1.1.3"
-- requests = ">=2.24.0"
-- zstandard = ">=0.20.0"
+- numpy= ">=1.23.5"
+- pandas = ">=1.5.3"
+- requests = ">=2.28.1"
+- zstandard = ">=0.21.0"
 
 ## Installation
 To install the latest stable version of the package from PyPI:

databento/live/gateway.py

@@ -1,9 +1,9 @@
 import asyncio
 import dataclasses
 import logging
-from functools import partial, singledispatch, update_wrapper
+from functools import partial, singledispatchmethod
 from io import BytesIO
-from typing import Any, Callable, Optional, Type, TypeVar, Union
+from typing import Optional, Type, TypeVar, Union
 
 from databento.common import cram
 from databento.common.enums import Compression, Dataset, Encoding, Schema, SType
@@ -16,32 +16,6 @@
 MIN_BUFFER_SIZE = 16 * 1024  # 16kB
 
 
-def singledispatchmethod(
-    func: Callable[..., Any],
-) -> Any:
-    """
-    Decorate a function to dispatch arguments by type.
-    This is a custom implementation of functools.singledispatchmethod.
-
-    See Also
-    --------
-    functools.singledispatch
-
-    Notes
-    -----
-    This should be removed when python 3.7 is no longer supported.
-
-    """
-    dispatcher: Any = singledispatch(func)
-
-    def _wrapper(*args: object, **kw: object) -> Any:
-        return dispatcher.dispatch(args[1].__class__)(*args, **kw)
-
-    setattr(_wrapper, "register", getattr(dispatcher, "register"))
-    update_wrapper(_wrapper, func)
-    return _wrapper
-
-
 @dataclasses.dataclass
 class GatewayControl:
     """

databento/version.py

@@ -1 +1 @@
-__version__ = "0.13.0"
+__version__ = "0.14.0"

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "databento"
-version = "0.13.0"
+version = "0.14.0"
 description = "Official Python client library for Databento"
 authors = [
     "Databento <[email protected]>",
@@ -24,13 +24,13 @@ repository = "https://github.com/databento/databento-python"
 "Bug Tracker" = "https://github.com/databento/databento-python/issues"
 
 [tool.poetry.dependencies]
-python = "^3.7"
-aiohttp = "^3.7.2"
+python = "^3.8"
+aiohttp = "^3.8.3"
 databento-dbn = "0.6.1"
-numpy= ">=1.17.0"
-pandas = ">=1.1.3"
+numpy= ">=1.23.5"
+pandas = ">=1.5.3"
 requests = ">=2.24.0"
-zstandard = ">=0.20.0"
+zstandard = ">=0.21.0"
 
 [tool.poetry.group.dev.dependencies]
 mypy = "1.2.0"
@@ -44,7 +44,7 @@ requires = ["poetry-core"]
 build-backend = "poetry.core.masonry.api"
 
 [tool.mypy]
-python_version = 3.7
+python_version = 3.8
 disallow_untyped_defs = true
 disallow_any_generics = true
 disallow_subclassing_any = true

tests/test_historical_batch.py

@@ -49,7 +49,6 @@ def test_batch_submit_job_given_invalid_stype_in_raises_error(self) -> None:
                 stype_in="zzz",  # <--- invalid
             )
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_batch_submit_job_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -101,7 +100,6 @@ def test_batch_submit_job_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_batch_list_jobs_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -130,7 +128,6 @@ def test_batch_list_jobs_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_batch_list_files_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -159,7 +156,6 @@ def test_batch_list_files_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_batch_download_single_file_sends_expected_request(
         self,
         mocker: MockerFixture,

tests/test_historical_client.py

@@ -96,7 +96,6 @@ def test_custom_gateway_force_https(
         # Assert
         assert client.gateway == expected
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_re_request_symbology_makes_expected_request(
         self,
         test_data_path: Callable[[Schema], pathlib.Path],
@@ -135,7 +134,6 @@ def test_re_request_symbology_makes_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_request_full_definitions_expected_request(
         self,
         test_data: Callable[[Schema], bytes],

tests/test_historical_error.py

@@ -35,7 +35,6 @@ def test_check_http_status(
 
 
 @pytest.mark.asyncio
-@pytest.mark.skipif(sys.version_info < (3, 8), reason="no async support for MagicMock")
 @pytest.mark.parametrize(
     "status_code, expected_exception, message",
     [

tests/test_historical_metadata.py

@@ -13,7 +13,6 @@ def setup_method(self) -> None:
         key = "DUMMY_API_KEY"
         self.client = db.Historical(key=key)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_list_publishers_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -38,7 +37,6 @@ def test_list_publishers_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_list_datasets_sends_expected_request(self, mocker: MockerFixture) -> None:
         # Arrange
         mocked_get = mocker.patch("requests.get")
@@ -65,7 +63,6 @@ def test_list_datasets_sends_expected_request(self, mocker: MockerFixture) -> No
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_list_schemas_sends_expected_request(self, mocker: MockerFixture) -> None:
         # Arrange
         mocked_get = mocker.patch("requests.get")
@@ -88,7 +85,6 @@ def test_list_schemas_sends_expected_request(self, mocker: MockerFixture) -> Non
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_list_fields_sends_expected_request(self, mocker: MockerFixture) -> None:
         # Arrange
         mocked_get = mocker.patch("requests.get")
@@ -117,7 +113,6 @@ def test_list_fields_sends_expected_request(self, mocker: MockerFixture) -> None
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     @pytest.mark.parametrize(
         "dataset, schema, mode",
         [
@@ -161,7 +156,6 @@ def test_list_unit_price_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_get_dataset_condition_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -193,7 +187,6 @@ def test_get_dataset_condition_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_get_dataset_range_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -221,7 +214,6 @@ def test_get_dataset_range_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_get_record_count_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -262,7 +254,6 @@ def test_get_record_count_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_get_billable_size_sends_expected_request(
         self,
         mocker: MockerFixture,
@@ -304,7 +295,6 @@ def test_get_billable_size_sends_expected_request(
         assert call["timeout"] == (100, 100)
         assert isinstance(call["auth"], requests.auth.HTTPBasicAuth)
 
-    @pytest.mark.skipif(sys.version_info < (3, 8), reason="incompatible mocking")
     def test_get_cost_sends_expected_request(self, mocker: MockerFixture) -> None:
         # Arrange
         mocked_get = mocker.patch("requests.get")