chore: Use mypy correctly and introduce ty

Author: edgarrmondragon

.github/workflows/ci.yml

@@ -3,11 +3,11 @@ name: Test Tap
 on:
   pull_request:
     paths-ignore:
-      - '**/README.md'
+      - "**/README.md"
   push:
     branches: [main]
     paths-ignore:
-      - '**/README.md'
+      - "**/README.md"
 
 env:
   FORCE_COLOR: 1
@@ -41,7 +41,7 @@ jobs:
           allow-prereleases: true
       - uses: astral-sh/setup-uv@85856786d1ce8acfbcc2f13a5f3fbd6b938f9f41 # v7.1.2
         with:
-          version: ">=0.5.19"
+          version: ">=0.9"
       - run: >
           uvx
           --with tox-uv

.pre-commit-config.yaml

@@ -45,12 +45,3 @@ repos:
   rev: 0.9.13
   hooks:
   - id: uv-lock
-
-- repo: https://github.com/pre-commit/mirrors-mypy
-  rev: v1.19.0
-  hooks:
-  - id: mypy
-    pass_filenames: true
-    additional_dependencies:
-    - types-requests
-    - types-PyYAML

pyproject.toml

@@ -35,7 +35,7 @@ dynamic = [ "version" ]
 dependencies = [
   "backports-datetime-fromisoformat~=2.0.1; python_full_version<'3.11'",
   "pyyaml~=6.0",
-  "singer-sdk>=0.52,<0.54",
+  "singer-sdk~=0.53.4",
   "typing-extensions>=4.14.1",
 ]
 
@@ -48,8 +48,11 @@ scripts.tap-dbt = "tap_dbt.tap:cli"
 dev = [
   "deptry>=0.14.2",
   "faker>=17.6",
-  "pytest>=8,<10",
+  "mypy>=1.19",
+  "pytest>=9",
   "responses~=0.25.0",
+  "ty>=0.0.1a29",
+  "types-pyyaml>=6.0.12.20250915",
   "types-requests>=2.32.4.20250809",
 ]
 
@@ -58,7 +61,7 @@ fallback-version = "0.0.0"
 source = "vcs"
 
 [tool.uv]
-required-version = ">=0.5.19"
+required-version = ">=0.9"
 
 [tool.ruff]
 line-length = 88
@@ -104,3 +107,9 @@ DEP002 = [ "backports-datetime-fromisoformat" ]
 
 [tool.pyproject-fmt]
 max_supported_python = "3.14"
+
+[tool.mypy]
+warn_redundant_casts = true
+warn_unreachable = true
+warn_unused_ignores = true
+warn_unused_configs = true

tap_dbt/client.py

@@ -3,9 +3,10 @@
 from __future__ import annotations
 
 import importlib.resources
-import typing as t
+import sys
 from abc import abstractmethod
 from functools import cache, cached_property
+from typing import Any
 
 import yaml
 from singer_sdk import RESTStream
@@ -15,9 +16,14 @@
 
 from tap_dbt import schemas
 
+if sys.version_info >= (3, 12):
+    from typing import override
+else:
+    from typing_extensions import override
+
 
 @cache
-def load_openapi(api_version: str) -> dict[str, t.Any]:
+def load_openapi(api_version: str) -> dict[str, Any]:
     """Load the OpenAPI specification from the package.
 
     Returns:
@@ -32,41 +38,44 @@ def load_openapi(api_version: str) -> dict[str, t.Any]:
 class DBTStream(RESTStream):
     """dbt stream class."""
 
-    primary_keys: t.ClassVar[list[str]] = ["id"]
+    primary_keys = ("id",)
     records_jsonpath = "$.data[*]"
     api_version = "v2"
 
+    @override
     @property
     def url_base(self) -> str:
         """Base URL for this stream."""
         base_url: str = self.config["base_url"]
         return f"{(base_url.rsplit('/', 1))[0]}/{self.api_version}"
 
+    @override
     @property
     def http_headers(self) -> dict:
         """HTTP headers for this stream."""
         headers = super().http_headers
         headers["Accept"] = "application/json"
         return headers
 
+    @override
     @property
     def authenticator(self) -> APIAuthenticatorBase:
         """Return the authenticator for this stream."""
         return SimpleAuthenticator(
-            stream=self,
             auth_headers={
                 "Authorization": f"Token {self.config.get('api_key')}",
             },
         )
 
-    def _resolve_openapi_ref(self) -> dict[str, t.Any]:
+    def _resolve_openapi_ref(self) -> dict[str, Any]:
         schema = {"$ref": f"#/components/schemas/{self.openapi_ref}"}
         openapi = load_openapi(self.api_version)
         schema["components"] = openapi["components"]
         return resolve_schema_references(schema)
 
+    @override
     @cached_property
-    def schema(self) -> dict[str, t.Any]:
+    def schema(self) -> dict[str, Any]:
         """Return the schema for this stream.
 
         Returns:
@@ -83,7 +92,7 @@ def append_null_nested(schema: dict) -> dict:
             if "properties" in schema:
                 new_schema["properties"] = {}
                 for p_name, p_schema in schema["properties"].items():
-                    if p_name not in self.primary_keys:
+                    if p_name not in self.primary_keys:  # ty: ignore[unsupported-operator]
                         new_schema["properties"][p_name] = append_null_nested(p_schema)
                     else:
                         new_schema["properties"][p_name] = p_schema