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

Turn off default httpavailabilitystrategy for source-linkedin-ads (GA) (#22013)

* Turn off default for source-linkedin-ads (GA)

* Update source.py

* Add missing changelog

* 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:48:29 -06:00
committed by GitHub
parent 68bbcdcbb2
commit 19e5982901
5 changed files with 10 additions and 4 deletions

View File

@@ -935,7 +935,7 @@
- name: LinkedIn Ads
sourceDefinitionId: 137ece28-5434-455c-8f34-69dc3782f451
dockerRepository: airbyte/source-linkedin-ads
dockerImageTag: 0.1.12
dockerImageTag: 0.1.13
documentationUrl: https://docs.airbyte.com/integrations/sources/linkedin-ads
icon: linkedin.svg
sourceType: api

View File

@@ -7626,7 +7626,7 @@
path_in_connector_config:
- "credentials"
- "client_secret"
- dockerImage: "airbyte/source-linkedin-ads:0.1.12"
- dockerImage: "airbyte/source-linkedin-ads:0.1.13"
spec:
documentationUrl: "https://docs.airbyte.com/integrations/sources/linkedin-ads"
connectionSpecification:

View File

@@ -33,5 +33,5 @@ COPY source_linkedin_ads ./source_linkedin_ads
ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
LABEL io.airbyte.version=0.1.12
LABEL io.airbyte.version=0.1.13
LABEL io.airbyte.name=airbyte/source-linkedin-ads

View File

@@ -14,6 +14,7 @@ from airbyte_cdk import AirbyteLogger
from airbyte_cdk.models import SyncMode
from airbyte_cdk.sources import AbstractSource
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.streams.http.auth import Oauth2Authenticator, TokenAuthenticator
from airbyte_cdk.sources.streams.http.exceptions import DefaultBackoffException
@@ -42,6 +43,10 @@ class LinkedinAdsStream(HttpStream, ABC):
"""Property to return the list of the user Account Ids from input"""
return ",".join(map(str, self.config.get("account_ids")))
@property
def availability_strategy(self) -> Optional["AvailabilityStrategy"]:
return None
def path(self, **kwargs) -> str:
"""Returns the API endpoint path for stream, from `endpoint` class attribute."""
return self.endpoint

View File

@@ -182,7 +182,8 @@ After 5 unsuccessful attempts - the connector will stop the sync operation. In s
## Changelog
| Version | Date | Pull Request | Subject |
| :------ | :--------- | :------------------------------------------------------- | :-------------------------------------------------------------------------------------------------------------- |
|:--------|:-----------|:---------------------------------------------------------| :-------------------------------------------------------------------------------------------------------------- |
| 0.1.13 | 2023-01-27 | [22013](https://github.com/airbytehq/airbyte/pull/22013) | for adDirectSponsoredContents stream skip accounts which are part of organization |
| 0.1.12 | 2022-10-18 | [18111](https://github.com/airbytehq/airbyte/pull/18111) | for adDirectSponsoredContents stream skip accounts which are part of organization |
| 0.1.11 | 2022-10-07 | [17724](https://github.com/airbytehq/airbyte/pull/17724) | Retry 429/5xx errors when refreshing access token |
| 0.1.10 | 2022-09-28 | [17326](https://github.com/airbytehq/airbyte/pull/17326) | Migrate to per-stream states. |