-
Notifications
You must be signed in to change notification settings - Fork 4.6k
Source S3: updates for compatibility with the concurrent CDK #34591
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
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,
|
57bced5
to
98b7dd8
Compare
98b7dd8
to
7d7fd18
Compare
7d7fd18
to
532cc10
Compare
532cc10
to
2ce72b5
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looks good!
@@ -21,14 +21,17 @@ | |||
|
|||
|
|||
class SourceS3(FileBasedSource): | |||
def read_config(self, config_path: str) -> Mapping[str, Any]: | |||
_concurrency_level = DEFAULT_CONCURRENCY |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
is there value in allowing the user to configure the concurrency level?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is to allow each source to turn on concurrency intentionally, instead of accidentally deploying it when the next version of the connector is deployed.
17a7c5e
to
2b188f8
Compare
2b188f8
to
ed7947a
Compare
ed7947a
to
59fb0e2
Compare
59fb0e2
to
a7e2ee2
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
90fe619
to
16db127
Compare
16db127
to
87d61e3
Compare
87d61e3
to
776bf56
Compare
776bf56
to
40ef2da
Compare
40ef2da
to
48b8f83
Compare
df35244
to
998f28a
Compare
998f28a
to
c4ae774
Compare
c4ae774
to
958e659
Compare
Add
catalog
,config
, andstate
to the args sent to the source, for compatibility with the concurrent CDK.Depends on #34411.