diff --git a/airbyte_cdk/sources/declarative/extractors/response_to_file_extractor.py b/airbyte_cdk/sources/declarative/extractors/response_to_file_extractor.py index eea4b80b2a..6a647335a0 100644 --- a/airbyte_cdk/sources/declarative/extractors/response_to_file_extractor.py +++ b/airbyte_cdk/sources/declarative/extractors/response_to_file_extractor.py @@ -113,7 +113,7 @@ def _save_to_file(self, response: requests.Response) -> Tuple[str, str]: return tmp_file, response_encoding else: raise ValueError( - f"The IO/Error occured while verifying binary data. Tmp file {tmp_file} doesn't exist." + f"The IO/Error occurred while verifying binary data. Tmp file {tmp_file} doesn't exist." ) def _read_with_chunks( @@ -147,7 +147,7 @@ def _read_with_chunks( self.logger.info(f"Empty data received. {e}") yield from [] except IOError as ioe: - raise ValueError(f"The IO/Error occured while reading tmp data. Called: {path}", ioe) + raise ValueError(f"The IO/Error occurred while reading tmp data. Called: {path}", ioe) finally: # remove binary tmp file, after data is read os.remove(path) diff --git a/airbyte_cdk/sources/file_based/exceptions.py b/airbyte_cdk/sources/file_based/exceptions.py index cd727463af..80c5ff2ae3 100644 --- a/airbyte_cdk/sources/file_based/exceptions.py +++ b/airbyte_cdk/sources/file_based/exceptions.py @@ -55,7 +55,7 @@ def yield_and_raise_collected(self) -> Any: # raising the single exception raise AirbyteTracedException( internal_message="Please check the logged errors for more information.", - message="Some errors occured while reading from the source.", + message="Some errors occurred while reading from the source.", failure_type=FailureType.config_error, )