file-based: add NotImplementedError

airbytehq · Feb 11, 2025 · a6d1b62 · a6d1b62
1 parent 4105c3c
commit a6d1b62
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__} required to support 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__} required to support load_identity_groups()"
+        )