file-based: add notImplemented error

airbytehq · Feb 5, 2025 · 1271e3a · 1271e3a
1 parent 4e5bb90
commit 1271e3a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/airbyte_cdk/sources/file_based/file_based_stream_reader.py b/airbyte_cdk/sources/file_based/file_based_stream_reader.py
@@ -191,12 +191,16 @@ def get_file_acl_permissions(self, file: RemoteFile, logger: logging.Logger) ->
         This is required for connectors that will support syncing
         ACL Permissions from files.
         """
-        ...
+        raise NotImplementedError(
+            f"{self.__class__.__name__} must implement get_file_acl_permissions()"
+        )
 
     @abstractmethod
     def load_identity_groups(self, logger: logging.Logger) -> Iterable[Dict[str, Any]]:
         """
         This is required for connectors that will support syncing
         identities.
         """
-        ...
+        raise NotImplementedError(
+            f"{self.__class__.__name__} must implement load_identity_groups()"
+        )