-
Notifications
You must be signed in to change notification settings - Fork 58
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
issue #3131 fix for run worker nodes #3163
Conversation
6aa8146
to
25c4130
Compare
…each worker run
25c4130
to
e43ec02
Compare
configuration.setEraseRunEndpoints(hasBooleanParameter(configuration, ERASE_WORKER_ENDPOINTS)); | ||
final Map<String, PipeConfValueVO> configParameters = MapUtils.isEmpty(configuration.getParameters()) ? | ||
new HashMap<>() : configuration.getParameters(); | ||
public PipelineConfiguration copyAsMasterConfiguration(final PipelineConfiguration configuration, |
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.
Maybe we should name the methods similar? generateMasterConfiguration
and generateWorkerConfiguration
final PipelineConfiguration runConfiguration; | ||
if (!StringUtils.hasText(clusterId)) { | ||
log.debug("Launching master entry {}", entry.getName()); | ||
runConfiguration = pipelineConfigurationManager.copyAsMasterConfiguration(configuration, startNFS); |
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.
We can return results immediately instead of assigning the variable
…each worker run
Now we are copy
runConfiguration
if we need it to be used as configuration for child runs.