Skip to content

Commit 5de4d25

Browse files
btkcodedevoctavia-squidington-iii
andauthoredMar 11, 2025··
Source Sendgrid: Update manifest for adapting changes with AsyncRetriever (#55185)
Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
1 parent a1801d7 commit 5de4d25

File tree

5 files changed

+14
-15
lines changed

5 files changed

+14
-15
lines changed
 

‎airbyte-integrations/connectors/source-sendgrid/acceptance-test-config.yml

+2
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,8 @@ acceptance_tests:
4343
bypass_reason: "can not populate"
4444
- name: blocks
4545
bypass_reason: "can not populate"
46+
- name: bounces
47+
bypass_reason: "can not populate"
4648
fail_on_extra_columns: false
4749
incremental:
4850
tests:

‎airbyte-integrations/connectors/source-sendgrid/integration_tests/expected_records.jsonl

-6
Original file line numberDiff line numberDiff line change
@@ -184,12 +184,6 @@
184184
{"stream": "suppression_group_members", "data": {"email": "test-forsuppressiongroup number8@example.com", "group_id": 14772, "group_name": "Test Suggestions Group 12", "created_at": 1612363238}, "emitted_at": 1631093393000}
185185
{"stream": "suppression_group_members", "data": {"email": "test-forsuppressiongroup number9@example.com", "group_id": 14772, "group_name": "Test Suggestions Group 12", "created_at": 1612363238}, "emitted_at": 1631093393000}
186186
{"stream": "suppression_group_members", "data": {"email": "avida.d3@gmail.com", "group_id": 14780, "group_name": "Test Suggestions Group 20", "created_at": 1631093329}, "emitted_at": 1631093393000}
187-
{"stream": "bounces", "data": {"status": "", "reason": "Invalid Domain", "email": "vadym.hevlich@zazmic_com", "created": 1621439283}, "emitted_at": 1708535996116}
188-
{"stream": "bounces", "data": {"status": "", "reason": "Invalid Domain", "email": "vadym.hevlich@zazmicinvalid", "created": 1621439221}, "emitted_at": 1708535996116}
189-
{"stream": "bounces", "data": {"status": "", "reason": "Invalid Domain", "email": "vadym.hevlich@zazmicio", "created": 1621439211}, "emitted_at": 1708535996116}
190-
{"stream": "bounces", "data": {"status": "", "reason": "Invalid Domain", "email": "vadym.hevlich@zazmiccom2", "created": 1621437507}, "emitted_at": 1708535996117}
191-
{"stream": "bounces", "data": {"status": "", "reason": "Invalid Domain", "email": "vadym.hevlich@zazmiccom1", "created": 1621437504}, "emitted_at": 1708535996117}
192-
{"stream": "bounces", "data": {"status": "", "reason": "Invalid Domain", "email": "vadym.hevlich@zazmiccom", "created": 1621426437}, "emitted_at": 1708535996117}
193187
{"stream": "campaigns", "data": {"created_at": "2021-09-08T09:07:48Z", "id": "3c5a9fa6-1084-11ec-ac32-4228d699bad5", "name": "Untitled Single Send", "status": "triggered", "updated_at": "2021-09-08T09:11:08Z", "is_abtest": false, "channels": ["email"]}, "emitted_at": 1678791750589}
194188
{"stream": "campaigns", "data": {"created_at": "2021-09-08T09:04:36Z", "id": "c9f286fb-1083-11ec-ae03-ca0fc7f28419", "name": "Copy of Untitled Single Send", "status": "triggered", "updated_at": "2021-09-08T09:09:08Z", "is_abtest": false, "channels": ["email"]}, "emitted_at": 1678791750589}
195189
{"stream": "campaigns", "data": {"created_at": "2021-09-08T08:53:59Z", "id": "4e5be6a3-1082-11ec-8512-9afd40c324e6", "name": "Untitled Single Send", "status": "triggered", "updated_at": "2021-09-08T08:57:08Z", "is_abtest": false, "channels": ["email"]}, "emitted_at": 1678791750590}

‎airbyte-integrations/connectors/source-sendgrid/manifest.yaml

+9-7
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
version: 5.13.0
1+
version: 6.38.3
22

33
type: DeclarativeSource
44

@@ -604,7 +604,7 @@ definitions:
604604
- timeout
605605
completed:
606606
- ready
607-
urls_extractor:
607+
download_target_extractor:
608608
type: DpathExtractor
609609
field_path:
610610
- urls
@@ -620,7 +620,7 @@ definitions:
620620
polling_requester:
621621
type: HttpRequester
622622
path: >-
623-
/v3/marketing/contacts/exports/{{stream_slice['create_job_response'].json()['id']
623+
/v3/marketing/contacts/exports/{{creation_response['id']
624624
}}
625625
url_base: https://api.sendgrid.com
626626
http_method: GET
@@ -637,11 +637,12 @@ definitions:
637637
api_token: "{{ config['api_key'] }}"
638638
download_requester:
639639
type: HttpRequester
640-
path: "{{stream_slice.extra_fields['url']}}"
641-
url_base: ""
640+
url_base: "{{download_target}}"
642641
http_method: GET
643-
download_extractor:
644-
type: ResponseToFileExtractor
642+
download_decoder:
643+
type: GzipDecoder
644+
decoder:
645+
type: CsvDecoder
645646
schema_loader:
646647
type: InlineSchemaLoader
647648
schema:
@@ -1066,6 +1067,7 @@ schemas:
10661067
type:
10671068
- 'null'
10681069
- array
1070+
- string
10691071
city:
10701072
type:
10711073
- string

‎airbyte-integrations/connectors/source-sendgrid/metadata.yaml

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,11 @@ data:
66
hosts:
77
- api.sendgrid.com
88
connectorBuildOptions:
9-
baseImage: docker.io/airbyte/source-declarative-manifest:6.36.1@sha256:52ad641b57995fbd43975d64f9a68fac15fcb80687df0f7acc27c4942a3b6bbb
9+
baseImage: docker.io/airbyte/source-declarative-manifest:6.38.3@sha256:fcba02266f262aabc2f37e4f14574aa1c8c5cffd018504bab28803e405c93afe
1010
connectorSubtype: api
1111
connectorType: source
1212
definitionId: fbb5fbe2-16ad-4cf4-af7d-ff9d9c316c87
13-
dockerImageTag: 1.2.9
13+
dockerImageTag: 1.3.0
1414
releases:
1515
breakingChanges:
1616
1.0.0:

‎docs/integrations/sources/sendgrid.md

+1
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,7 @@ The connector is restricted by normal Sendgrid [requests limitation](https://doc
8989

9090
| Version | Date | Pull Request | Subject |
9191
|:--------|:-----------| :------------------------------------------------------- |:--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
92+
| 1.3.0 | 2025-03-04 | [55185](https://github.com/airbytehq/airbyte/pull/55185) | Update manifest for adapting changes with AsyncRetriever |
9293
| 1.2.9 | 2025-02-23 | [54625](https://github.com/airbytehq/airbyte/pull/54625) | Update dependencies |
9394
| 1.2.8 | 2025-02-15 | [54013](https://github.com/airbytehq/airbyte/pull/54013) | Update dependencies |
9495
| 1.2.7 | 2025-02-08 | [53508](https://github.com/airbytehq/airbyte/pull/53508) | Update dependencies |

0 commit comments

Comments
 (0)
Please sign in to comment.