Skip to content

Commit

Permalink
Turn off default httpavailabilitystrategy for source-klaviyo (GA) (#2…
Browse files Browse the repository at this point in the history
…2012)

* Turn off default for source-klaviyo (GA)

* Update streams.py

* Update klaviyo.md

* auto-bump connector version

---------

Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
  • Loading branch information
erohmensing and octavia-squidington-iii authored Jan 28, 2023
1 parent 68bcced commit 9fe98ad
Show file tree
Hide file tree
Showing 5 changed files with 9 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -896,7 +896,7 @@
- name: Klaviyo
sourceDefinitionId: 95e8cffd-b8c4-4039-968e-d32fb4a69bde
dockerRepository: airbyte/source-klaviyo
dockerImageTag: 0.1.10
dockerImageTag: 0.1.11
documentationUrl: https://docs.airbyte.com/integrations/sources/klaviyo
icon: klaviyo.svg
sourceType: api
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7375,7 +7375,7 @@
supportsNormalization: false
supportsDBT: false
supported_destination_sync_modes: []
- dockerImage: "airbyte/source-klaviyo:0.1.10"
- dockerImage: "airbyte/source-klaviyo:0.1.11"
spec:
documentationUrl: "https://docs.airbyte.com/integrations/sources/klaviyo"
changelogUrl: "https://docs.airbyte.com/integrations/sources/klaviyo"
Expand Down
2 changes: 1 addition & 1 deletion airbyte-integrations/connectors/source-klaviyo/Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -34,5 +34,5 @@ COPY source_klaviyo ./source_klaviyo
ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]

LABEL io.airbyte.version=0.1.10
LABEL io.airbyte.version=0.1.11
LABEL io.airbyte.name=airbyte/source-klaviyo
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@

import pendulum
import requests
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

Expand All @@ -27,6 +28,10 @@ def __init__(self, api_key: str, **kwargs):
transform_function = self.get_custom_transform()
self.transformer.registerCustomTransform(transform_function)

@property
def availability_strategy(self) -> Optional["AvailabilityStrategy"]:
return None

def get_custom_transform(self):
def custom_transform_date_rfc3339(original_value, field_schema):
if original_value and "format" in field_schema and field_schema["format"] == "date-time":
Expand Down
1 change: 1 addition & 0 deletions docs/integrations/sources/klaviyo.md
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,7 @@ The Klaviyo connector should not run into Klaviyo API limitations under normal u

| Version | Date | Pull Request | Subject |
|:---------|:-----------|:-----------------------------------------------------------|:------------------------------------------------------------------------------------------|
| `0.1.11` | 2023-01-27 | [22012](https://github.com/airbytehq/airbyte/pull/22012) | Set `AvailabilityStrategy` for streams explicitly to `None` |
| `0.1.10` | 2022-09-29 | [17422](https://github.com/airbytehq/airbyte/issues/17422) | Update CDK dependency |
| `0.1.9` | 2022-09-28 | [17304](https://github.com/airbytehq/airbyte/issues/17304) | Migrate to per-stream state. |
| `0.1.6` | 2022-07-20 | [14872](https://github.com/airbytehq/airbyte/issues/14872) | Increase test coverage |
Expand Down

0 comments on commit 9fe98ad

Please sign in to comment.