tell mypy to ignore lint errors

Author: dbgold17

airbyte_cdk/connector_builder/connector_builder_handler.py

@@ -48,7 +48,7 @@ def should_migrate_manifest(config: Mapping[str, Any]) -> bool:
 
     This flag is set by the UI.
     """
-    return config.get("__should_migrate", False)
+    return config.get("__should_migrate", False)  # type: ignore[no-any-return]
 
 
 def should_normalize_manifest(config: Mapping[str, Any]) -> bool:
@@ -57,7 +57,7 @@ def should_normalize_manifest(config: Mapping[str, Any]) -> bool:
     :param config: The configuration to check
     :return: True if the manifest should be normalized, False otherwise.
     """
-    return config.get("__should_normalize", False)
+    return config.get("__should_normalize", False)  # type: ignore[no-any-return]
 
 
 def create_source(

airbyte_cdk/manifest_server/command_processor/utils.py

@@ -1,3 +1,5 @@
+# Copyright (c) 2025 Airbyte, Inc., all rights reserved.
+
 import copy
 from typing import Any, Dict, List, Mapping, Optional
 
@@ -42,7 +44,7 @@ def should_migrate_manifest(manifest: Mapping[str, Any]) -> bool:
 
     This flag is set by the UI.
     """
-    return manifest.get(SHOULD_MIGRATE_KEY, False)
+    return bool(manifest.get(SHOULD_MIGRATE_KEY, False))
 
 
 def should_normalize_manifest(manifest: Mapping[str, Any]) -> bool:
@@ -52,7 +54,7 @@ def should_normalize_manifest(manifest: Mapping[str, Any]) -> bool:
 
     This flag is set by the UI.
     """
-    return manifest.get(SHOULD_NORMALIZE_KEY, False)
+    return bool(manifest.get(SHOULD_NORMALIZE_KEY, False))
 
 
 def build_source(

airbyte_cdk/sources/declarative/interpolation/macros.py

@@ -11,8 +11,8 @@
 from urllib.parse import quote_plus
 
 import isodate
-import pytz
-from dateutil import parser
+import pytz  # type: ignore[import-untyped]
+from dateutil import parser  # type: ignore[import-untyped]
 from isodate import parse_duration
 
 from airbyte_cdk.sources.declarative.datetime.datetime_parser import DatetimeParser
@@ -90,7 +90,7 @@ def str_to_datetime(s: str) -> datetime.datetime:
     if not parsed_date.tzinfo:
         # Assume UTC if the input does not contain a timezone
         parsed_date = parsed_date.replace(tzinfo=pytz.utc)
-    return parsed_date.astimezone(pytz.utc)
+    return parsed_date.astimezone(pytz.utc)  # type: ignore[no-any-return]
 
 
 def max(*args: typing.Any) -> typing.Any:

airbyte_cdk/sources/file_based/stream/default_file_based_stream.py

@@ -19,7 +19,6 @@
     NoReturn,
     Optional,
     Set,
-    Tuple,
     Union,
 )
 
@@ -93,7 +92,7 @@ def state(self, value: MutableMapping[str, Any]) -> None:
     def cursor(self) -> Optional[AbstractFileBasedCursor]:
         return self._cursor
 
-    @cursor.setter
+    @cursor.setter  # type: ignore[override]
     def cursor(self, value: AbstractFileBasedCursor) -> None:
         if self._cursor is not None:
             raise RuntimeError(

airbyte_cdk/sources/streams/checkpoint/checkpoint_reader.py

@@ -247,19 +247,19 @@ def next(self) -> Optional[Mapping[str, Any]]:
         try:
             self.current_slice = self._find_next_slice()
 
-            if "partition" in dict(self.current_slice):
+            if "partition" in dict(self.current_slice):  # type: ignore[arg-type]
                 raise ValueError("Stream is configured to use invalid stream slice key 'partition'")
-            elif "cursor_slice" in dict(self.current_slice):
+            elif "cursor_slice" in dict(self.current_slice):  # type: ignore[arg-type]
                 raise ValueError(
                     "Stream is configured to use invalid stream slice key 'cursor_slice'"
                 )
 
             # We convert StreamSlice to a regular mapping because legacy connectors operate on the basic Mapping object. We
             # also duplicate all fields at the top level for backwards compatibility for existing Python sources
             return {
-                "partition": self.current_slice.partition,
-                "cursor_slice": self.current_slice.cursor_slice,
-                **dict(self.current_slice),
+                "partition": self.current_slice.partition,  # type: ignore[union-attr]
+                "cursor_slice": self.current_slice.cursor_slice,  # type: ignore[union-attr]
+                **dict(self.current_slice),  # type: ignore[arg-type]
             }
         except StopIteration:
             self._finished_sync = True