handle submitted failure (#726)

Netflix · Nov 14, 2024 · 325d23d · 325d23d
1 parent 4da2e05
commit 325d23d
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java b/...src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java
@@ -288,7 +288,7 @@ private void onSubmittedScheduleRequestEvent(SubmittedScheduleRequestEvent event
         try {
             final TaskExecutorRegistration info = resourceCluster.getTaskExecutorInfo(taskExecutorID)
                 .join();
-            boolean success =
+            boolean success = //todo this return state is not wired to actual processing
                 jobMessageRouter.routeWorkerEvent(new WorkerLaunched(
                     event.getEvent().getRequest().getWorkerId(),
                     event.getEvent().getRequest().getStageNum(),
@@ -308,6 +308,7 @@ private void onSubmittedScheduleRequestEvent(SubmittedScheduleRequestEvent event
             }
         } catch (Exception ex) {
             log.warn("Failed to route message due to error in getting TaskExecutor info: {}", taskExecutorID, ex);
+            self().tell(event.onFailure(ex), self());
         }
     }
 
@@ -520,6 +521,11 @@ private static class SubmittedScheduleRequestEvent {
 
         ScheduleRequestEvent event;
         TaskExecutorID taskExecutorID;
+
+        FailedToScheduleRequestEvent onFailure(Throwable throwable) {
+            return new FailedToScheduleRequestEvent(
+                this.event, 1, ExceptionUtils.stripCompletionException(throwable));
+        }
     }
 
     @Value