If the client wants to submit the latest job cluster definition, resp…

…ect that. (#440) * If skipSubmit is present, ignoring the absence of job definition * Whatever --------- Co-authored-by: Sundaram Ananthanarayanan <sananthanarayanan@netflix.com>
Netflix · May 16, 2023 · 5034b7b · 5034b7b
1 parent ff31e56
commit 5034b7b
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/...tis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java b/...tis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java
@@ -1420,17 +1420,18 @@ private boolean requireJobActorProcess(final SubmitJobRequest request) {
         if (!jobInfoForNonTerminalJob.isPresent()) {
             logger.info("Last job id doesn't map to job info instance, skip job actor process. {}", lastJobId.get());
             return false;
-        }
-        else if (!givenJobDefn.isPresent()) {
+        } else if (request.isSubmitLatest()) {
+            logger.info("Submit latest job request, skip job actor process. {}", request);
+            return false;
+        } else if (!givenJobDefn.isPresent()) {
             logger.info("[QuickSubmit] pass to job actor to process job definition: {}", lastJobId.get());
             jobInfoForNonTerminalJob.get().jobActor.tell(
                     new GetJobDefinitionUpdatedFromJobActorRequest(
                             user, lastJobId.get(), jobInfoForNonTerminalJob.get().jobDefinition,
                             true, request.isAutoResubmit(), getSender()),
                     getSelf());
             return true;
-        }
-        else if (givenJobDefn.get().requireInheritInstanceCheck()) {
+        } else if (givenJobDefn.get().requireInheritInstanceCheck()) {
             logger.info("[Inherit request] pass to job actor to process job definition: {}", lastJobId.get());
             jobInfoForNonTerminalJob.get().jobActor.tell(
                     new GetJobDefinitionUpdatedFromJobActorRequest(