diff --git a/airbyte_cdk/sources/file_based/file_based_stream_reader.py b/airbyte_cdk/sources/file_based/file_based_stream_reader.py
index 099b401f7..23894b5e1 100644
--- a/airbyte_cdk/sources/file_based/file_based_stream_reader.py
+++ b/airbyte_cdk/sources/file_based/file_based_stream_reader.py
@@ -191,7 +191,9 @@ 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]]:
@@ -199,4 +201,6 @@ 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()"
+        )