-
Notifications
You must be signed in to change notification settings - Fork 336
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
SAMZA-2233: Allow overriding descriptor generated task.inputs using configs #1065
Conversation
@Sanil15 Can you please take a look for TestRunner changes. |
"Specify them using InputDescriptors instead. Ignoring configured task.inputs value of " + | ||
userConfig.get(TaskConfig.INPUT_STREAMS())); | ||
// Don't allow overriding task.inputs to a blank string | ||
if (StringUtils.isBlank(userConfig.get(TaskConfig.INPUT_STREAMS()))) { |
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.
Why is this check required?
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.
samza app-def sets task.inputs = "" by default, so we need to ignore that. It's a simple and useful enough check that I kept this in OSS instead of patching in LI.
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.
Thanks for the changes, LGTM!
3271f68
to
ee0af24
Compare
No description provided.