Skip to content

Commit 2a70786

Browse files
Quinn-With-Two-NsQuinn-With-Two-Ns
committed
fix format error
1 parent 80b1c1d commit 2a70786

1 file changed

Lines changed: 40 additions & 41 deletions

File tree

‎temporal-spring-boot-autoconfigure/src/main/java/io/temporal/spring/boot/autoconfigure/template/WorkerOptionsTemplate.java‎

Lines changed: 40 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -71,50 +71,49 @@ WorkerOptions createWorkerOptions() {
7171
.ifPresent(options::setNexusTaskPollersBehavior);
7272
}
7373
}
74+
}
7475

75-
WorkerProperties.RateLimitsConfigurationProperties rateLimitConfiguration =
76-
workerProperties.getRateLimits();
77-
if (rateLimitConfiguration != null) {
78-
Optional.ofNullable(rateLimitConfiguration.getMaxWorkerActivitiesPerSecond())
79-
.ifPresent(options::setMaxWorkerActivitiesPerSecond);
80-
Optional.ofNullable(rateLimitConfiguration.getMaxTaskQueueActivitiesPerSecond())
81-
.ifPresent(options::setMaxTaskQueueActivitiesPerSecond);
82-
}
76+
WorkerProperties.RateLimitsConfigurationProperties rateLimitConfiguration =
77+
workerProperties.getRateLimits();
78+
if (rateLimitConfiguration != null) {
79+
Optional.ofNullable(rateLimitConfiguration.getMaxWorkerActivitiesPerSecond())
80+
.ifPresent(options::setMaxWorkerActivitiesPerSecond);
81+
Optional.ofNullable(rateLimitConfiguration.getMaxTaskQueueActivitiesPerSecond())
82+
.ifPresent(options::setMaxTaskQueueActivitiesPerSecond);
83+
}
8384

84-
WorkerProperties.BuildIdConfigurationProperties buildIdConfigurations =
85-
workerProperties.getBuildId();
86-
if (buildIdConfigurations != null) {
87-
Optional.ofNullable(buildIdConfigurations.getWorkerBuildId())
88-
.ifPresent(options::setBuildId);
89-
options.setUseBuildIdForVersioning(buildIdConfigurations.getEnabledWorkerVersioning());
90-
}
85+
WorkerProperties.BuildIdConfigurationProperties buildIdConfigurations =
86+
workerProperties.getBuildId();
87+
if (buildIdConfigurations != null) {
88+
Optional.ofNullable(buildIdConfigurations.getWorkerBuildId()).ifPresent(options::setBuildId);
89+
options.setUseBuildIdForVersioning(buildIdConfigurations.getEnabledWorkerVersioning());
90+
}
9191

92-
WorkerProperties.VirtualThreadConfigurationProperties virtualThreadConfiguration =
93-
workerProperties.getVirtualThreads();
94-
if (virtualThreadConfiguration != null) {
95-
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreads())
96-
.ifPresent(options::setUsingVirtualThreads);
97-
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnWorkflowWorker())
98-
.ifPresent(options::setUsingVirtualThreadsOnWorkflowWorker);
99-
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnActivityWorker())
100-
.ifPresent(options::setUsingVirtualThreadsOnActivityWorker);
101-
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnLocalActivityWorker())
102-
.ifPresent(options::setUsingVirtualThreadsOnLocalActivityWorker);
103-
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnNexusWorker())
104-
.ifPresent(options::setUsingVirtualThreadsOnNexusWorker);
105-
}
106-
WorkerProperties.WorkerDeploymentConfigurationProperties workerDeploymentConfiguration =
107-
workerProperties.getDeploymentProperties();
108-
if (workerDeploymentConfiguration != null) {
109-
WorkerDeploymentOptions.Builder opts = WorkerDeploymentOptions.newBuilder();
110-
Optional.ofNullable(workerDeploymentConfiguration.getUseVersioning())
111-
.ifPresent(opts::setUseVersioning);
112-
Optional.ofNullable(workerDeploymentConfiguration.getDeploymentVersion())
113-
.ifPresent((v) -> opts.setVersion(WorkerDeploymentVersion.fromCanonicalString(v)));
114-
Optional.ofNullable(workerDeploymentConfiguration.getDefaultVersioningBehavior())
115-
.ifPresent(opts::setDefaultVersioningBehavior);
116-
options.setDeploymentOptions(opts.build());
117-
}
92+
WorkerProperties.VirtualThreadConfigurationProperties virtualThreadConfiguration =
93+
workerProperties.getVirtualThreads();
94+
if (virtualThreadConfiguration != null) {
95+
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreads())
96+
.ifPresent(options::setUsingVirtualThreads);
97+
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnWorkflowWorker())
98+
.ifPresent(options::setUsingVirtualThreadsOnWorkflowWorker);
99+
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnActivityWorker())
100+
.ifPresent(options::setUsingVirtualThreadsOnActivityWorker);
101+
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnLocalActivityWorker())
102+
.ifPresent(options::setUsingVirtualThreadsOnLocalActivityWorker);
103+
Optional.ofNullable(virtualThreadConfiguration.isUsingVirtualThreadsOnNexusWorker())
104+
.ifPresent(options::setUsingVirtualThreadsOnNexusWorker);
105+
}
106+
WorkerProperties.WorkerDeploymentConfigurationProperties workerDeploymentConfiguration =
107+
workerProperties.getDeploymentProperties();
108+
if (workerDeploymentConfiguration != null) {
109+
WorkerDeploymentOptions.Builder opts = WorkerDeploymentOptions.newBuilder();
110+
Optional.ofNullable(workerDeploymentConfiguration.getUseVersioning())
111+
.ifPresent(opts::setUseVersioning);
112+
Optional.ofNullable(workerDeploymentConfiguration.getDeploymentVersion())
113+
.ifPresent((v) -> opts.setVersion(WorkerDeploymentVersion.fromCanonicalString(v)));
114+
Optional.ofNullable(workerDeploymentConfiguration.getDefaultVersioningBehavior())
115+
.ifPresent(opts::setDefaultVersioningBehavior);
116+
options.setDeploymentOptions(opts.build());
118117
}
119118

120119
if (customizer != null) {

0 commit comments

Comments
 (0)