1
0
mirror of synced 2025-12-20 18:39:31 -05:00
Commit Graph

1266 Commits

Author SHA1 Message Date
maxi297
106102c52c 🤖 Bump patch version of Python CDK 2024-03-07 15:51:14 +00:00
Maxime Carbonneau-Leclerc
858e61d67a Declarative CDK: Fix None error on stream_slice (#35879) 2024-03-07 10:43:58 -05:00
girarda
1d9e5463c6 🤖 Bump patch version of Python CDK 2024-03-06 02:58:12 +00:00
Alexandre Girard
f55abc1fdc 🐛 low-code: Fix incremental substreams (#35471) 2024-03-05 18:50:42 -08:00
girarda
4b3a9bffc6 🤖 Bump patch version of Python CDK 2024-03-06 00:24:53 +00:00
girarda
67c918b6fb 🤖 Bump minor version of Python CDK 2024-03-06 00:09:26 +00:00
Alexandre Girard
5f48da9a67 [low-code] allow page size to be defined with string interpolation (#35735)
Co-authored-by: Dan Lecocq <dlecocq@sofi.org>
2024-03-05 16:03:16 -08:00
clnoll
16c00da3ee 🤖 Bump patch version of Python CDK 2024-03-05 19:53:22 +00:00
Catherine Noll
7e4649eb30 CDK: upgrade pyarrow (#35818) 2024-03-05 13:07:08 -05:00
erohmensing
bf7e158169 🤖 Bump patch version of Python CDK 2024-03-05 17:58:59 +00:00
Ella Rohm-Ensing
a090088594 file cdk: handle scalar values that resolve to None (#35688)
<!--
Thanks for your contribution! 
Before you submit the pull request, 
I'd like to kindly remind you to take a moment and read through our guidelines
to ensure that your contribution aligns with the type of contributions our project accepts.
All the information you need can be found here:
   https://docs.airbyte.com/contributing-to-airbyte/

We truly appreciate your interest in contributing to Airbyte,
and we're excited to see what you have to offer! 

If you have any questions or need any assistance, feel free to reach out in #contributions Slack channel.
-->

## What
* Closes https://github.com/airbytehq/airbyte/issues/34151
* Closes https://github.com/airbytehq/oncall/issues/4386

## How
Handle cases where the python value of a pyarrow scalar is None. This can be due to null values in data, as well as null-like values like `NaT` (similar to `NaN`). We previously handled this for `None` binary types, but now handle this for `None` of any type.

## 🚨 User Impact 🚨
No breaking changes. After this CDK version is released we should update the CDK dependency in S3 and any other file sources that parse parquet


## Pre-merge Actions
*Expand the relevant checklist and delete the others.*

<details><summary><strong>New Connector</strong></summary>

### Community member or Airbyter

- **Community member?** Grant edit access to maintainers ([instructions](https://docs.github.com/en/github/collaborating-with-pull-requests/working-with-forks/allowing-changes-to-a-pull-request-branch-created-from-a-fork#enabling-repository-maintainer-permissions-on-existing-pull-requests))
- Unit & integration tests added and passing. Community members, please provide proof of success locally e.g: screenshot or copy-paste unit, integration, and acceptance test output. To run acceptance tests for a Python connector, follow instructions in the README. For java connectors run `./gradlew :airbyte-integrations:connectors:<name>:integrationTest`.
- Connector version is set to `0.0.1`
    - `Dockerfile` has version `0.0.1`
- Documentation updated
    - Connector's `README.md`
    - Connector's `bootstrap.md`. See [description and examples](https://docs.google.com/document/d/1ypdgmwmEHWv-TrO4_YOQ7pAJGVrMp5BOkEVh831N260/edit?usp=sharing)
    - `docs/integrations/<source or destination>/<name>.md` including changelog with an entry for the initial version. See changelog [example](https://docs.airbyte.io/integrations/sources/stripe#changelog)
    - `docs/integrations/README.md`

### Airbyter

If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.

- Create a non-forked branch based on this PR and test the below items on it
- Build is successful
- If new credentials are required for use in CI, add them to GSM. [Instructions](https://docs.airbyte.io/connector-development#using-credentials-in-ci).

</details>

<details><summary><strong>Updating a connector</strong></summary>

### Community member or Airbyter

- Grant edit access to maintainers ([instructions](https://docs.github.com/en/github/collaborating-with-pull-requests/working-with-forks/allowing-changes-to-a-pull-request-branch-created-from-a-fork#enabling-repository-maintainer-permissions-on-existing-pull-requests))
- Unit & integration tests added


### Airbyter

If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.

- Create a non-forked branch based on this PR and test the below items on it
- Build is successful
- If new credentials are required for use in CI, add them to GSM. [Instructions](https://docs.airbyte.io/connector-development#using-credentials-in-ci).

</details>

<details><summary><strong>Connector Generator</strong></summary>

- Issue acceptance criteria met
- PR name follows [PR naming conventions](https://docs.airbyte.com/contributing-to-airbyte/resources/pull-requests-handbook)
- If adding a new generator, add it to the [list of scaffold modules being tested](https://github.com/airbytehq/airbyte/blob/master/airbyte-integrations/connector-templates/generator/build.gradle#L41)
- The generator test modules (all connectors with `-scaffold` in their name) have been updated with the latest scaffold by running `./gradlew :airbyte-integrations:connector-templates:generator:generateScaffolds` then checking in your changes
- Documentation which references the generator is updated as needed

</details>

<details><summary><strong>Updating the Python CDK</strong></summary>

### Airbyter

Before merging:
- Pull Request description explains what problem it is solving
- Code change is unit tested
- Build and my-py check pass
- Smoke test the change on at least one affected connector
   - On Github: Run [this workflow](https://github.com/airbytehq/airbyte/actions/workflows/connectors_tests.yml), passing `--use-local-cdk --name=source-<connector>` as options
   - Locally: `airbyte-ci connectors --use-local-cdk --name=source-<connector> test`
- PR is reviewed and approved
      
After merging:
- [Publish the CDK](https://github.com/airbytehq/airbyte/actions/workflows/publish-cdk-command-manually.yml)
   - The CDK does not follow proper semantic versioning. Choose minor if this the change has significant user impact or is a breaking change. Choose patch otherwise.
   - Write a thoughtful changelog message so we know what was updated.
- Merge the platform PR that was auto-created for updating the Connector Builder's CDK version
   - This step is optional if the change does not affect the connector builder or declarative connectors.

</details>
2024-03-05 09:07:02 -08:00
Ella Rohm-Ensing
08dd7de8f8 file cdk: fix typing, pull out non-scalar handling (#35687)
<!--
Thanks for your contribution! 
Before you submit the pull request, 
I'd like to kindly remind you to take a moment and read through our guidelines
to ensure that your contribution aligns with the type of contributions our project accepts.
All the information you need can be found here:
   https://docs.airbyte.com/contributing-to-airbyte/

We truly appreciate your interest in contributing to Airbyte,
and we're excited to see what you have to offer! 

If you have any questions or need any assistance, feel free to reach out in #contributions Slack channel.
-->

## What
* Fix typing and handling of different types in `_to_output_value` - we don't always get a `Scalar`. We already handle the different cases correctly, but the typing doesn't reflect this. 
* Splitting out the methods to do the scalar separately is a helpful precursor to https://github.com/airbytehq/airbyte/pull/35688, as the `DictionaryArray` object doesn't have an `as_py()` method.

## 🚨 User Impact 🚨
None

## Pre-merge Actions
*Expand the relevant checklist and delete the others.*

<details><summary><strong>New Connector</strong></summary>

### Community member or Airbyter

- **Community member?** Grant edit access to maintainers ([instructions](https://docs.github.com/en/github/collaborating-with-pull-requests/working-with-forks/allowing-changes-to-a-pull-request-branch-created-from-a-fork#enabling-repository-maintainer-permissions-on-existing-pull-requests))
- Unit & integration tests added and passing. Community members, please provide proof of success locally e.g: screenshot or copy-paste unit, integration, and acceptance test output. To run acceptance tests for a Python connector, follow instructions in the README. For java connectors run `./gradlew :airbyte-integrations:connectors:<name>:integrationTest`.
- Connector version is set to `0.0.1`
    - `Dockerfile` has version `0.0.1`
- Documentation updated
    - Connector's `README.md`
    - Connector's `bootstrap.md`. See [description and examples](https://docs.google.com/document/d/1ypdgmwmEHWv-TrO4_YOQ7pAJGVrMp5BOkEVh831N260/edit?usp=sharing)
    - `docs/integrations/<source or destination>/<name>.md` including changelog with an entry for the initial version. See changelog [example](https://docs.airbyte.io/integrations/sources/stripe#changelog)
    - `docs/integrations/README.md`

### Airbyter

If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.

- Create a non-forked branch based on this PR and test the below items on it
- Build is successful
- If new credentials are required for use in CI, add them to GSM. [Instructions](https://docs.airbyte.io/connector-development#using-credentials-in-ci).

</details>

<details><summary><strong>Updating a connector</strong></summary>

### Community member or Airbyter

- Grant edit access to maintainers ([instructions](https://docs.github.com/en/github/collaborating-with-pull-requests/working-with-forks/allowing-changes-to-a-pull-request-branch-created-from-a-fork#enabling-repository-maintainer-permissions-on-existing-pull-requests))
- Unit & integration tests added


### Airbyter

If this is a community PR, the Airbyte engineer reviewing this PR is responsible for the below items.

- Create a non-forked branch based on this PR and test the below items on it
- Build is successful
- If new credentials are required for use in CI, add them to GSM. [Instructions](https://docs.airbyte.io/connector-development#using-credentials-in-ci).

</details>

<details><summary><strong>Connector Generator</strong></summary>

- Issue acceptance criteria met
- PR name follows [PR naming conventions](https://docs.airbyte.com/contributing-to-airbyte/resources/pull-requests-handbook)
- If adding a new generator, add it to the [list of scaffold modules being tested](https://github.com/airbytehq/airbyte/blob/master/airbyte-integrations/connector-templates/generator/build.gradle#L41)
- The generator test modules (all connectors with `-scaffold` in their name) have been updated with the latest scaffold by running `./gradlew :airbyte-integrations:connector-templates:generator:generateScaffolds` then checking in your changes
- Documentation which references the generator is updated as needed

</details>

<details><summary><strong>Updating the Python CDK</strong></summary>

### Airbyter

Before merging:
- Pull Request description explains what problem it is solving
- Code change is unit tested
- Build and my-py check pass
- Smoke test the change on at least one affected connector
   - On Github: Run [this workflow](https://github.com/airbytehq/airbyte/actions/workflows/connectors_tests.yml), passing `--use-local-cdk --name=source-<connector>` as options
   - Locally: `airbyte-ci connectors --use-local-cdk --name=source-<connector> test`
- PR is reviewed and approved
      
After merging:
- [Publish the CDK](https://github.com/airbytehq/airbyte/actions/workflows/publish-cdk-command-manually.yml)
   - The CDK does not follow proper semantic versioning. Choose minor if this the change has significant user impact or is a breaking change. Choose patch otherwise.
   - Write a thoughtful changelog message so we know what was updated.
- Merge the platform PR that was auto-created for updating the Connector Builder's CDK version
   - This step is optional if the change does not affect the connector builder or declarative connectors.

</details>
2024-03-05 08:56:52 -08:00
Brian Lai
ef98194673 Emit final state message for full refresh syncs and consolidate read flows (#35622) 2024-03-05 01:05:06 -05:00
ambirdsall
a3d1bb1844 🤖 Bump patch version of Python CDK 2024-02-28 18:58:17 +00:00
Marius Posta
fdfd048225 python CDK: fix gradle task dependency (#35609) 2024-02-27 11:01:38 -08:00
Danny Tiesling
e671aa320d 🐛 Source S3: fix exception when setting CSV stream delimiter to \t. (#35246)
Co-authored-by: Marcos Marx <marcosmarxm@users.noreply.github.com>
Co-authored-by: marcosmarxm <marcosmarxm@gmail.com>
2024-02-23 14:34:29 -03:00
artem1205
fbe0e8c6f3 🤖 Bump minor version of Python CDK 2024-02-22 19:12:42 +00:00
Artem Inzhyyants
970b24b30c Airbyte CDK: add CustomRecordFilter (#35283)
Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>
2024-02-22 20:06:53 +01:00
artem1205
34956a1285 🤖 Bump minor version of Python CDK 2024-02-22 18:46:52 +00:00
Artem Inzhyyants
0954ad3d3a Airbyte CDK: add interpolation for request options (#35485)
Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>
Co-authored-by: Alexandre Girard <alexandre@airbyte.io>
2024-02-22 19:40:44 +01:00
girarda
9cb2371460 🤖 Bump minor version of Python CDK 2024-02-21 22:20:18 +00:00
Alexandre Girard
5724ca0cf0 Add ignore_stream_slicer_parameters_on_paginated_requests flag (#35462) 2024-02-21 14:14:37 -08:00
ambirdsall
c9b7d8acb2 🤖 Bump patch version of Python CDK 2024-02-21 21:49:35 +00:00
artem1205
198971bb21 🤖 Bump minor version of Python CDK 2024-02-21 12:58:36 +00:00
Artem Inzhyyants
3355c5c432 Airbyte CDK: add filter to RemoveFields (#35326)
Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>
2024-02-21 13:49:10 +01:00
ambirdsall
c99c0b1333 🤖 Bump patch version of Python CDK 2024-02-16 23:59:31 +00:00
Alex Birdsall
385a70d89d Support user-specified test read limits in connector_builder code (#35312) 2024-02-16 15:53:26 -08:00
Marius Posta
dc088bc3a9 gradle: split off python cdk (#35306) 2024-02-16 04:39:14 -08:00
clnoll
8e7618f845 🤖 Bump patch version of Python CDK 2024-02-15 14:57:53 +00:00
Catherine Noll
5a202f7ed4 File-based CDK: enqueue AirbyteMessage of type record instead of sending to the message repository (#35318) 2024-02-15 09:38:07 -05:00
brianjlai
daa92a9825 🤖 Bump minor version of Python CDK 2024-02-15 07:45:35 +00:00
Brian Lai
2b87164b89 Emit multiple error trace messages and continue syncs by default (#35129) 2024-02-15 02:16:02 -05:00
girarda
3bd4b149f6 🤖 Bump patch version of Python CDK 2024-02-15 06:32:30 +00:00
Alexandre Girard
fc87183905 🐛 python cdk: mask oauth access key (#34931) 2024-02-14 22:25:18 -08:00
maxi297
083c573899 🤖 Bump patch version of Python CDK 2024-02-09 17:25:36 +00:00
Maxime Carbonneau-Leclerc
60a2618154 [ISSUE #34910] add headers to HttpResponse for test framework (#35105) 2024-02-09 12:19:29 -05:00
Catherine Noll
936ce03cfc CDK: allow ConnectorStateManager stream_instance_map to take ConfiguredAirbyteStream or Stream (#35000) 2024-02-08 11:22:09 -05:00
clnoll
9933916792 🤖 Bump minor version of Python CDK 2024-02-08 03:48:25 +00:00
Catherine Noll
e8910e427a File-based CDK: make incremental syncs concurrent (#34540) 2024-02-07 20:41:04 -05:00
Brian Lai
60686505f3 Revert "Emit multiple error trace messages and continue syncs by default" (#34990) 2024-02-07 19:47:15 -05:00
maxi297
c38b80dcd7 🤖 Bump patch version of Python CDK 2024-02-07 20:47:32 +00:00
Maxime Carbonneau-Leclerc
3d9f70f9b0 [ISSUE #34755] do not propagate parameters on InlineSchemaLoader (#34853) 2024-02-07 15:41:03 -05:00
Brian Lai
cc2a6e229f Emit multiple error trace messages and continue syncs by default (#34636) 2024-02-07 13:34:43 -05:00
lmossman
e1f79251ea 🤖 Bump patch version of Python CDK 2024-02-07 18:19:39 +00:00
Lake Mossman
f281672a07 fix version of airbyte-cdk in Dockerfile pip install (#34941) 2024-02-07 10:06:53 -08:00
Catherine Noll
7f97f245bc CDK: fix flaky scenario-based tests by sorting on k & v (#34912) 2024-02-06 18:55:39 -05:00
clnoll
18de9d1f4b 🤖 Bump minor version of Python CDK 2024-02-06 20:51:04 +00:00
Catherine Noll
be80bfc57c File-based CDK: log warning on no sync mode instead of raising exception (#34924) 2024-02-06 15:36:34 -05:00
maxi297
c7a7b93dfa 🤖 Bump patch version of Python CDK 2024-02-05 18:12:39 +00:00
Maxime Carbonneau-Leclerc
06d44f8138 Improve error messages for concurrent CDK (#34754) 2024-02-05 13:05:41 -05:00