Skip to content

Source Salesforce: Update streams.py for adapting changes with AsyncRetriever#55186

Merged
Maxime Carbonneau-Leclerc (maxi297) merged 14 commits into
masterfrom
btkcodedev/salesforceUpdateAsyncRetriever
Mar 20, 2025
Merged

Source Salesforce: Update streams.py for adapting changes with AsyncRetriever#55186
Maxime Carbonneau-Leclerc (maxi297) merged 14 commits into
masterfrom
btkcodedev/salesforceUpdateAsyncRetriever

Conversation

@btkcodedev
Copy link
Copy Markdown
Contributor

What

Closes https://github.com/airbytehq/airbyte-internal-issues/issues/11791

How

In specific:

  • upgrade the CDK version to at least 6.36.3

  • rename the urls_extractor to download_target_extractor, here and here

  • move off the stream_slice interpolation context to use the {{creation_response['id']}}, here

  • make sure the CAT passes, as before

  • make sure the Regression Tests pass, as before

  • no source behaviour changes are expected

@btkcodedev btkcodedev (btkcodedev) requested a review from a team as a code owner March 4, 2025 13:09
@vercel
Copy link
Copy Markdown

vercel Bot commented Mar 4, 2025

The latest updates on your projects. Learn more about Vercel for Git ↗︎

Name Status Preview Comments Updated (UTC)
airbyte-docs ✅ Ready (Inspect) Visit Preview 💬 Add feedback Mar 19, 2025 9:11pm

@btkcodedev
Copy link
Copy Markdown
Contributor Author

btkcodedev (btkcodedev) commented Mar 4, 2025

/bump-version type="minor" changelog="Update manifest for adapting changes with AsyncRetriever"

Bump Version job started... Check job output.

✅ Changes applied successfully. (611224c)

@maxi297
Copy link
Copy Markdown
Contributor

Tests are failing because of TypeError: AsyncHttpJobRepository.__init__() got an unexpected keyword argument 'download_target_extractor' (and maybe for other reasons). Let me know when this is ready for a review and I'll check it out!

@bazarnov
Copy link
Copy Markdown
Contributor

Tests are failing because of TypeError: AsyncHttpJobRepository.__init__() got an unexpected keyword argument 'download_target_extractor' (and maybe for other reasons). Let me know when this is ready for a review and I'll check it out!

Because of this, here:

airbyte-cdk = "^5.10.2"

The version should be:

airbyte-cdk = "^6.33.3"

@btkcodedev
Copy link
Copy Markdown
Contributor Author

Thanks Baz (@bazarnov) That helps!!

@maxi297
Copy link
Copy Markdown
Contributor

Maxime Carbonneau-Leclerc (maxi297) commented Mar 18, 2025

Hey btkcodedev (@btkcodedev), thanks for the contribution! It turns out that this was more complex than anticipated. Hence, I pushed some changes. The tests will still fail. This is expected at this point. We need this fix from the CDK. Once the CDK release is done, we can up the version here and the tests should be green. At that point, I'll ask a review from another extensibility member

@maxi297
Copy link
Copy Markdown
Contributor

This recent change has created a regression where we don't retry on timed out jobs. I've started a thread internally to try to understand why we have this change

@maxi297
Copy link
Copy Markdown
Contributor

Everything has been updated. CATs are failing but they are failing the same way on master so I think I'm fine with this. Baz (@bazarnov) can you have a review on this?

Copy link
Copy Markdown
Contributor

@bazarnov Baz (bazarnov) left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks great!

The CAT issues are about the "expected records." Some "IDs" are not matching, which is a relatively straightforward problem that can be easily resolved by updating the exptected_records. btkcodedev (@btkcodedev)

@bazarnov
Copy link
Copy Markdown
Contributor

Baz (bazarnov) commented Mar 19, 2025

/approve-regression-tests

Check job output.

✅ Approving regression tests

@btkcodedev
Copy link
Copy Markdown
Contributor Author

btkcodedev (btkcodedev) commented Mar 19, 2025

Baz (@bazarnov) Can we declare ActiveFeatureLicenseMetric as empty stream?

Ref:
[95m158 : �[0m �[90m[5m15.2s] �[0m�[90m|�[0m INFO control-read:models.py:396 Reading records for stream ActiveFeatureLicenseMetric
�[95m158 : �[0m �[90m[5m15.2s] �[0m�[90m|�[0m WARNING control-read:models.py:398 No records found for stream ActiveFeatureLicenseMetric
�[95m158 : �[0m �[90m[5m15.2s] �[0m�[90m|�[0m INFO test_all_pks_are_produced_in_target_version_without_state[CONNECTION c3b48b1]:test_read.py:74 Retrieving primary keys for stream ActiveFeatureLicenseMetric on target version.

@btkcodedev
Copy link
Copy Markdown
Contributor Author

btkcodedev (btkcodedev) commented Mar 19, 2025

/format-fix

Format-fix job started... Check job output.

✅ Changes applied successfully. (a2f13c8)

@bazarnov
Copy link
Copy Markdown
Contributor

Baz (bazarnov) commented Mar 20, 2025

/approve-regression-tests

Check job output.

✅ Approving regression tests

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Merging this. Thanks btkcodedev (@btkcodedev) !

@maxi297 Maxime Carbonneau-Leclerc (maxi297) deleted the btkcodedev/salesforceUpdateAsyncRetriever branch March 20, 2025 12:48
Sven Pöche (Valgard) pushed a commit to mayflower/airbyte that referenced this pull request Mar 25, 2025
…etriever (airbytehq#55186)

Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
Co-authored-by: Danylo Jablonski <150933663+DanyloGL@users.noreply.github.com>
Co-authored-by: maxi297 <maxime@airbyte.io>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area/connectors Connector related issues area/documentation Improvements or additions to documentation connectors/source/salesforce

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants