Repository navigation
Source Salesforce: use concurrent CDK for full refresh syncs - #32535
Conversation
|
The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Ignored Deployment
|
Before Merging a Connector Pull RequestWow! What a great pull request you have here! 🎉 To merge this PR, ensure the following has been done/considered for each connector added or updated:
If the checklist is complete, but the CI check is failing,
|
|
Catherine Noll (@clnoll) I'm updating your branch so that you get the fresh CI workflow for format |
6a608e3 to
9979861
Compare
Alexandre Girard (girarda)
left a comment
There was a problem hiding this comment.
looks great
!
| ), | ||
| ), | ||
| ) | ||
| def test_unspecified_and_incremental_streams_are_not_concurrent(stream_config, stream_names, catalog_stream_names) -> None: |
There was a problem hiding this comment.
what's an unspecified stream?
There was a problem hiding this comment.
This just means the catalog hasn't been set. It shouldn't happen during reads but I thought it was worth testing just in case.
Maxime Carbonneau-Leclerc (maxi297)
left a comment
There was a problem hiding this comment.
Awesome! 🎉
|
|
||
| def _get_sync_mode_from_catalog(self, stream: Stream) -> Optional[SyncMode]: | ||
| if self.catalog: | ||
| for catalog_stream in self.catalog.streams: |
There was a problem hiding this comment.
Outside of the scope of this PR: I see this looping logic more and more. Would there be a way to have a ConfiguredAirbyteCatalog.get_stream_by_name(name: str)? This would greatly improve the readability/maintenance of our code
Serhii Lazebnyi (lazebnyi)
left a comment
There was a problem hiding this comment.
nice!
4c8a7e4 to
6ef3f0e
Compare
99026bf to
968ba5c
Compare
1ea0549 to
968ba5c
Compare
4e0715d to
5b05106
Compare
5b05106 to
d24d535
Compare
d24d535 to
de6bc9f
Compare
de6bc9f to
295d4d2
Compare
295d4d2 to
db6d007
Compare
Adds concurrency to the Source Salesforce connector, for streams that are configured for full refresh.