From b74a0059d801a0f8d8796d7d01f3de60d1df80ba Mon Sep 17 00:00:00 2001
From: Aldo Gonzalez <aldo.gonzalez@airbyte.io>
Date: Tue, 11 Feb 2025 14:36:59 -0600
Subject: [PATCH] file-based: update messages for not implemented errors

---
 .../sources/file_based/file_based_stream_reader.py        | 8 ++++----
 1 file changed, 4 insertions(+), 4 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
index 4b81d98a2..789d0c3a9 100644
--- a/airbyte_cdk/sources/file_based/file_based_stream_reader.py
+++ b/airbyte_cdk/sources/file_based/file_based_stream_reader.py
@@ -192,7 +192,7 @@ def get_file_acl_permissions(self, file: RemoteFile, logger: logging.Logger) ->
         ACL Permissions from files.
         """
         raise NotImplementedError(
-            f"{self.__class__.__name__} required to support ACL permissions, please update file_permissions_schema accordingly."
+            f"{self.__class__.__name__} does not implement get_file_acl_permissions(). To support ACL permissions, implement this method and update file_permissions_schema."
         )
 
     @abstractmethod
@@ -202,7 +202,7 @@ def load_identity_groups(self, logger: logging.Logger) -> Iterable[Dict[str, Any
         identities.
         """
         raise NotImplementedError(
-            f"{self.__class__.__name__} required to support identities, please update identities_schema."
+            f"{self.__class__.__name__} does not implement load_identity_groups(). To support identities, implement this method and update identities_schema."
         )
 
     @property
@@ -213,7 +213,7 @@ def file_permissions_schema(self) -> Dict[str, Any]:
         ACL Permissions from files.
         """
         raise NotImplementedError(
-            f"{self.__class__.__name__} required to support ACL Permissions, please return required json schema for your permissions streams."
+            f"{self.__class__.__name__} does not implement file_permissions_schema, please return json schema for your permissions streams."
         )
 
     @property
@@ -224,5 +224,5 @@ def identities_schema(self) -> Dict[str, Any]:
         identities.
         """
         raise NotImplementedError(
-            f"{self.__class__.__name__} required to support fetch Identities, please return required json schema for your Identities stream."
+            f"{self.__class__.__name__} does not implement identities_schema, please return json schema for your identities stream."
         )