refactor(source-salesforce): Replace AirbyteLogger with logging.Logger

airbyte-integrations/connectors/source-salesforce/metadata.yaml

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: b117307c-14b6-41aa-9422-947e34922962
-  dockerImageTag: 2.5.11
+  dockerImageTag: 2.5.12
   dockerRepository: airbyte/source-salesforce
   documentationUrl: https://docs.airbyte.com/integrations/sources/salesforce
   githubIssueLabel: source-salesforce

airbyte-integrations/connectors/source-salesforce/pyproject.toml

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "2.5.11"
+version = "2.5.12"
 name = "source-salesforce"
 description = "Source implementation for Salesforce."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-salesforce/source_salesforce/exceptions.py

@@ -3,14 +3,14 @@
 #
 
 
-from airbyte_cdk.logger import AirbyteLogger
+import logging
 
 
 class Error(Exception):
     """Base Error class for other exceptions"""
 
     # Define the instance of the Native Airbyte Logger
-    logger = AirbyteLogger()
+    logger = logging.getLogger("airbyte")
 
 
 class SalesforceException(Exception):

airbyte-integrations/connectors/source-salesforce/source_salesforce/source.py

@@ -9,7 +9,6 @@
 import isodate
 import pendulum
 import requests
-from airbyte_cdk import AirbyteLogger
 from airbyte_cdk.logger import AirbyteLogFormatter
 from airbyte_cdk.models import AirbyteMessage, AirbyteStateMessage, ConfiguredAirbyteCatalog, ConfiguredAirbyteStream, Level, SyncMode
 from airbyte_cdk.sources.concurrent_source.concurrent_source import ConcurrentSource
@@ -91,7 +90,7 @@ def _validate_stream_slice_step(stream_slice_step: str):
                 internal_message = "Incorrect stream slice step"
                 raise AirbyteTracedException(failure_type=FailureType.config_error, internal_message=internal_message, message=e.args[0])
 
-    def check_connection(self, logger: AirbyteLogger, config: Mapping[str, Any]) -> Tuple[bool, Optional[str]]:
+    def check_connection(self, logger: logging.Logger, config: Mapping[str, Any]) -> Tuple[bool, Optional[str]]:
         self._validate_stream_slice_step(config.get("stream_slice_step"))
         try:
             salesforce = self._get_sf_object(config)

docs/integrations/sources/salesforce.md

@@ -192,6 +192,7 @@ Now that you have set up the Salesforce source connector, check out the followin
 
 | Version | Date       | Pull Request                                             | Subject                                                                                                                              |
 | :------ | :--------- | :------------------------------------------------------- | :----------------------------------------------------------------------------------------------------------------------------------- |
+| 2.5.12  | 2024-05-15 | [38255](https://github.com/airbytehq/airbyte/pull/38255) | Replace AirbyteLogger with logging.Logger |
 | 2.5.11  | 2024-05-09 | [38205](https://github.com/airbytehq/airbyte/pull/38205)      | Use new delete method of HttpMocker for test_bulk_stream                                                                        |
 | 2.5.10  | 2024-05-09 | [38065](https://github.com/airbytehq/airbyte/pull/38065) | Replace deprecated authentication mechanism to up-to-date one                                                                        |
 | 2.5.9   | 2024-05-02 | [37749](https://github.com/airbytehq/airbyte/pull/37749) | Adding mock server tests for bulk streams                                                                                            |