-
Notifications
You must be signed in to change notification settings - Fork 1.4k
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
chore(sources): Add SourceContext #4685
Conversation
To inject the `Resolver` similar to the `TransformContext`. I need the `Resolver` in the new `aws_s3` source. I figured I'd submit this change separately since it was easy to pull out and I wanted thoughts sooner than later. Alternatively, it seems like the resolver is static now so we could drop it from `SinkContext` and `TransformContext`. I wanted some confirmation on that front though. I'm happy to reverse this and remove injection of the `Resolver`. Signed-off-by: Jesse Szwedko <jesse@szwedko.me>
Signed-off-by: Jesse Szwedko <jesse@szwedko.me>
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.
Since Resolver
is already halfway removed, I don't think it's worth adding SourceContext
just for that. We may well need it for other things later, but better to defer until that time.
In the source where you need it, I would just create one yourself.
@lukesteensen makes sense, thanks for the validation! Would it be worth me creating a PR to drop the |
We decided in #2812 to keep passing |
Hmm, actually, given @ktff's reference to the decision in #2812 I'm actually inclined to add the |
I did say that, didn't I... To be clear, I think the intention of that comment was that we continue to provide a resolver interface, not that we necessarily continue to thread it through contexts. The mentioned benefit of threading an executor is not really a valid one anymore, and we have definitely decided not to let the behavior be configurable. So it would be perfectly fine in my opinion to have something as simple as a top-level On the other hand, it doesn't really matter that much. We should be consistent and there's no urgency to moving away from the threaded resolvers on other contexts, so I would be totally fine going in this direction for now and revisiting later. |
👍 Sorry, that was my mistake in not being clearer. I meant to ask if I should, instead of adding the It's definitely not urgent, but the rough edge there did lead to some confusion on my part, initially, and I can see it doing the same for others. This is the comment that led me to believe that adding I'm fine to go either way though 😄 |
Yes, I meant to communicate that this is my preference, sorry 😄 |
😄 I'll close this and open a new PR for removing it. |
Also resolve a couple of TODOs that are stale. Just create the Resolver pending #4685 Remove comment about FIFO handling as it seems to be the same from the consumer side as a standard queue. Signed-off-by: Jesse Szwedko <jesse@szwedko.me>
Also resolve a couple of TODOs that are stale. Just create the Resolver pending #4685 Remove comment about FIFO handling as it seems to be the same from the consumer side as a standard queue. Signed-off-by: Jesse Szwedko <jesse@szwedko.me>
To inject the
Resolver
similar to theTransformContext
. I need theResolver
in the newaws_s3
source. I figured I'd submit this changeseparately since it was easy to pull out and I wanted thoughts sooner
than later.
Alternatively, it seems like the resolver is static now so we could drop
it from
SinkContext
andTransformContext
. I wanted some confirmationon that front though. I'm happy to reverse this and remove injection of
the
Resolver
.Signed-off-by: Jesse Szwedko jesse@szwedko.me