Cleaning up log

Netflix · Oct 16, 2023 · fd490bc · fd490bc
1 parent cd735c5
commit fd490bc
Showing 1 changed file with 13 additions and 11 deletions.
diff --git a/...-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java b/...-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java
@@ -56,17 +56,19 @@ public MantisScheduler forClusterID(@Nullable ClusterID clusterID) {
             ActorRef resourceClusterAwareSchedulerActor =
                 actorRefMap.computeIfAbsent(
                     clusterID,
-                    (cid) -> actorSystem.actorOf(
-                        ResourceClusterAwareSchedulerActor.props(
-                            masterConfiguration.getSchedulerMaxRetries(),
-                            masterConfiguration.getSchedulerMaxRetries(),
-                            masterConfiguration.getSchedulerIntervalBetweenRetries(),
-                            resourceClusters.getClusterFor(cid),
-                            executeStageRequestFactory,
-                            jobMessageRouter,
-                            metricsRegistry),
-                        "scheduler-for-" + cid.getResourceID()));
-            log.info("Created scheduler actor for cluster: {}", clusterIDOptional.get().getResourceID());
+                    (cid) -> {
+                        log.info("Created scheduler actor for cluster: {}", clusterIDOptional.get().getResourceID());
+                        return actorSystem.actorOf(
+                            ResourceClusterAwareSchedulerActor.props(
+                                masterConfiguration.getSchedulerMaxRetries(),
+                                masterConfiguration.getSchedulerMaxRetries(),
+                                masterConfiguration.getSchedulerIntervalBetweenRetries(),
+                                resourceClusters.getClusterFor(cid),
+                                executeStageRequestFactory,
+                                jobMessageRouter,
+                                metricsRegistry),
+                            "scheduler-for-" + cid.getResourceID())
+                    });
             return new ResourceClusterAwareScheduler(resourceClusterAwareSchedulerActor);
         } else {
             return mesosSchedulingService;