Source: Salesforce - Upgrade API to v60.0

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

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: b117307c-14b6-41aa-9422-947e34922962
-  dockerImageTag: 2.6.4
+  dockerImageTag: 2.6.5
   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.6.4"
+version = "2.6.5"
 name = "source-salesforce"
 description = "Source implementation for Salesforce."
 authors = [ "Airbyte <[email protected]>",]

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

@@ -223,7 +223,7 @@
 
 class Salesforce:
     logger = logging.getLogger("airbyte")
-    version = "v57.0"
+    version = "v62.0"
     parallel_tasks_size = 100
     # https://developer.salesforce.com/docs/atlas.en-us.salesforce_app_limits_cheatsheet.meta/salesforce_app_limits_cheatsheet/salesforce_app_limits_platform_api.htm
     # Request Size Limits

airbyte-integrations/connectors/source-salesforce/unit_tests/api_test.py

@@ -143,7 +143,7 @@ def _prepare_mock(m, stream):
 
 
 def _bulk_stream_path() -> str:
-    return f"/services/data/v57.0/jobs/query"
+    return f"/services/data/v62.0/jobs/query"
 
 
 def _get_result_id(stream):
@@ -239,7 +239,7 @@ def test_check_connection_rate_limit(
     with requests_mock.Mocker() as m:
         m.register_uri("POST", "https://login.salesforce.com/services/oauth2/token", json=login_json_resp, status_code=login_status_code)
         m.register_uri(
-            "GET", "https://instance_url/services/data/v57.0/sobjects", json=discovery_resp_json, status_code=discovery_status_code
+            "GET", "https://instance_url/services/data/v62.0/sobjects", json=discovery_resp_json, status_code=discovery_status_code
         )
         with pytest.raises(AirbyteTracedException) as exception:
             source.check_connection(logger, stream_config)
@@ -258,7 +258,7 @@ def test_pagination_rest(stream_config, stream_api):
     stream_name = "AcceptedEventRelation"
     stream: RestSalesforceStream = generate_stream(stream_name, stream_config, stream_api)
     stream.DEFAULT_WAIT_TIMEOUT = timedelta(seconds=6)
-    next_page_url = "/services/data/v57.0/query/012345"
+    next_page_url = "/services/data/v62.0/query/012345"
     with requests_mock.Mocker() as m:
         resp_1 = {
             "done": False,
@@ -491,7 +491,7 @@ def test_too_many_properties(stream_config, stream_api_v2_pk_too_many_properties
     assert stream.too_many_properties
     assert stream.primary_key
     assert type(stream) == RestSalesforceStream
-    url = next_page_url = "https://fase-account.salesforce.com/services/data/v57.0/queryAll"
+    url = next_page_url = "https://fase-account.salesforce.com/services/data/v62.0/queryAll"
     requests_mock.get(
         url,
         [
@@ -532,7 +532,7 @@ def test_stream_with_no_records_in_response(stream_config, stream_api_v2_pk_too_
     assert stream.too_many_properties
     assert stream.primary_key
     assert type(stream) == RestSalesforceStream
-    url = "https://fase-account.salesforce.com/services/data/v57.0/queryAll"
+    url = "https://fase-account.salesforce.com/services/data/v62.0/queryAll"
     requests_mock.get(
         url,
         [

airbyte-integrations/connectors/source-salesforce/unit_tests/integration/utils.py

@@ -17,7 +17,7 @@
 from airbyte_cdk.test.state_builder import StateBuilder
 
 
-_API_VERSION = "v57.0"
+_API_VERSION = "v62.0"
 
 
 def _catalog(stream_name: str, sync_mode: SyncMode) -> ConfiguredAirbyteCatalog:

airbyte-integrations/connectors/source-salesforce/unit_tests/resource/http/response/job_response.json

@@ -8,7 +8,7 @@
   "state": "UploadComplete",
   "concurrencyMode": "Parallel",
   "contentType": "CSV",
-  "apiVersion": 57.0,
+  "apiVersion": 62.0,
   "lineEnding": "LF",
   "columnDelimiter": "COMMA"
 }

airbyte-integrations/connectors/source-salesforce/unit_tests/test_rate_limiting.py

@@ -15,7 +15,7 @@
 
 _ANY = "any"
 _ANY_BASE_URL = "https://any-base-url.com"
-_SF_API_VERSION = "v57.0"
+_SF_API_VERSION = "v62.0"
 
 
 class SalesforceErrorHandlerTest(TestCase):

docs/integrations/sources/salesforce.md

@@ -219,6 +219,7 @@ Now that you have set up the Salesforce source connector, check out the followin
 
 | Version | Date       | Pull Request                                             | Subject                                                                                                                             |
 |:--------|:-----------|:---------------------------------------------------------|:------------------------------------------------------------------------------------------------------------------------------------|
+| 2.6.5 | 2025-02-07 | [XXXXX](https://github.com/airbytehq/airbyte/pull/XXXXX) | Upgrade to API v62.0 |
 | 2.6.4 | 2025-01-11 | [48635](https://github.com/airbytehq/airbyte/pull/48635) | Starting with this version, the Docker image is now rootless. Please note that this and future versions will not be compatible with Airbyte versions earlier than 0.64 |
 | 2.6.3 | 2024-11-05 | [46835](https://github.com/airbytehq/airbyte/pull/46835) | Update dependencies |
 | 2.6.2 | 2024-10-10 | [](https://github.com/airbytehq/airbyte/pull/) | Bump minimum CDK to 5.10.2 |