1
0
mirror of synced 2025-12-25 02:09:19 -05:00

Turn off default httpavailabilitystrategy for source-salesforce (GA) (#22016)

* Turn off default for source-salesforce (GA)

* Update streams.py

* Update salesforce.md

* Update salesforce.md

* auto-bump connector version

---------

Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
This commit is contained in:
Ella Rohm-Ensing
2023-01-27 23:49:20 -06:00
committed by GitHub
parent 19e5982901
commit 86c0f664b4
5 changed files with 9 additions and 3 deletions

View File

@@ -1544,7 +1544,7 @@
- name: Salesforce
sourceDefinitionId: b117307c-14b6-41aa-9422-947e34922962
dockerRepository: airbyte/source-salesforce
dockerImageTag: 1.0.29
dockerImageTag: 1.0.30
documentationUrl: https://docs.airbyte.com/integrations/sources/salesforce
icon: salesforce.svg
sourceType: api

View File

@@ -13095,7 +13095,7 @@
supportsNormalization: false
supportsDBT: false
supported_destination_sync_modes: []
- dockerImage: "airbyte/source-salesforce:1.0.29"
- dockerImage: "airbyte/source-salesforce:1.0.30"
spec:
documentationUrl: "https://docs.airbyte.com/integrations/sources/salesforce"
connectionSpecification:

View File

@@ -13,5 +13,5 @@ RUN pip install .
ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
LABEL io.airbyte.version=1.0.29
LABEL io.airbyte.version=1.0.30
LABEL io.airbyte.name=airbyte/source-salesforce

View File

@@ -16,6 +16,7 @@ import pendulum
import requests # type: ignore[import]
from airbyte_cdk.models import ConfiguredAirbyteCatalog, SyncMode
from airbyte_cdk.sources.streams import Stream
from airbyte_cdk.sources.streams.availability_strategy import AvailabilityStrategy
from airbyte_cdk.sources.streams.http import HttpStream
from airbyte_cdk.sources.utils.transform import TransformConfig, TypeTransformer
from numpy import nan
@@ -60,6 +61,10 @@ class SalesforceStream(HttpStream, ABC):
def url_base(self) -> str:
return self.sf_api.instance_url
@property
def availability_strategy(self) -> Optional["AvailabilityStrategy"]:
return None
def path(self, next_page_token: Mapping[str, Any] = None, **kwargs: Any) -> str:
if next_page_token:
"""

View File

@@ -129,6 +129,7 @@ Now that you have set up the Salesforce source connector, check out the followin
| Version | Date | Pull Request | Subject |
|:--------|:-----------|:---------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------|
| 1.0.30 | 2023-01-27 | [22016](https://github.com/airbytehq/airbyte/pull/22016) | Set `AvailabilityStrategy` for streams explicitly to `None` |
| 1.0.29 | 2023-01-05 | [20886](https://github.com/airbytehq/airbyte/pull/20886) | Remove `ActivityMetric` stream |
| 1.0.28 | 2022-12-29 | [20927](https://github.com/airbytehq/airbyte/pull/20927) | Fix tests; add expected records |
| 1.0.27 | 2022-11-29 | [19869](https://github.com/airbytehq/airbyte/pull/19869) | Remove `AccountHistory` from unsupported BULK streams |