From 1271e3a7b7aa2489101c6bde3b95297ea2c659b3 Mon Sep 17 00:00:00 2001 From: Aldo Gonzalez Date: Wed, 5 Feb 2025 08:47:06 -0600 Subject: [PATCH] file-based: add notImplemented error --- .../sources/file_based/file_based_stream_reader.py | 8 ++++++-- 1 file changed, 6 insertions(+), 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 index 099b401f7..c9d91bccb 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__} must implement 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__} must implement load_identity_groups()" + )