File tree Expand file tree Collapse file tree
temporal-sdk/src/main/java/io/temporal/internal/worker Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -102,7 +102,7 @@ public boolean start() {
102102 pollerOptions .getUncaughtExceptionHandler ()));
103103 pollExecutor = exec ;
104104 for (PollTaskAsync <T > asyncTaskPoller : asyncTaskPollers ) {
105- log .info ("Starting async poller: {} !!!! " , asyncTaskPoller );
105+ log .info ("Starting async poller: {}" , asyncTaskPoller . getLabel () );
106106 AdjustableSemaphore pollerSemaphore =
107107 new AdjustableSemaphore (pollerBehavior .getInitialMaxConcurrentTaskPollers ());
108108 PollScaleReportHandle <T > pollScaleReportHandle =
@@ -112,7 +112,9 @@ public boolean start() {
112112 pollerBehavior .getInitialMaxConcurrentTaskPollers (),
113113 (newTarget ) -> {
114114 log .info (
115- "Updating maximum number of pollers to: {} for {}" , newTarget , asyncTaskPoller );
115+ "Updating maximum number of pollers for {} to: {}" ,
116+ asyncTaskPoller .getLabel (),
117+ newTarget );
116118 pollerSemaphore .setMaxPermits (newTarget );
117119 });
118120 PollQueueTask pollQueue =
@@ -155,7 +157,7 @@ default void cancel(Throwable cause) {
155157 }
156158
157159 default String getLabel () {
158- return "AsyncPollTask " ;
160+ return "PollTaskAsync " ;
159161 }
160162 }
161163
You can’t perform that action at this time.
0 commit comments