stop checking nodes altogether after a dirty shutdown

Author: Riliane

src/test/java/org/jenkinsci/plugins/workflow/cps/FlowDurabilityTest.java

@@ -250,6 +250,20 @@ static void verifySucceededCleanly(Jenkins j, WorkflowRun run) throws Exception
         assertHasTimingAction(run.getExecution());
     }
 
+    /** A minimal check of resuming the job with no node checks, in case of a dirty shutdown.
+     * Currently dirty shutdowns have the potential to lose the head node ID if they happen at the moment of writing
+     * it to build.xml
+     */
+    static void verifyDirtyResumed(JenkinsRule rule, WorkflowRun run, String logStart) throws Exception {
+        assert run.isBuilding();
+        assertHasTimingAction(run.getExecution());
+        rule.waitForCompletion(run);
+        Assert.assertEquals(Result.SUCCESS, run.getResult());
+        verifyCompletedCleanly(rule.jenkins, run);
+        //no checking nodes
+        rule.assertLogContains(logStart, run);
+    }
+
     /** If it's a {@link SemaphoreStep} we test less rigorously because that blocks async GraphListeners. */
     static void verifySafelyResumed(JenkinsRule rule, WorkflowRun run, boolean isSemaphore, String logStart) throws Exception {
         assert run.isBuilding();
@@ -716,7 +730,6 @@ public void evaluate() throws Throwable {
                 WorkflowRun run = createAndRunSleeperJob(story.j.jenkins, jobName, FlowDurabilityHint.MAX_SURVIVABILITY, false);
                 FlowExecution exec = run.getExecution();
                 if (exec instanceof CpsFlowExecution) {
-                    ((CpsFlowExecution) exec).waitForSuspension(); // till done writing head node ID into build.xml
                     assert ((CpsFlowExecution) exec).getStorage().isPersistedFully();
                 }
                 logStart[0] = JenkinsRule.getLog(run);
@@ -727,7 +740,7 @@ public void evaluate() throws Throwable {
             @Override
             public void evaluate() throws Throwable {
                 WorkflowRun run = story.j.jenkins.getItemByFullName(jobName, WorkflowJob.class).getLastBuild();
-                verifySafelyResumed(story.j, run, false, logStart[0]);
+                verifyDirtyResumed(story.j, run, logStart[0]);
             }
         });
     }
@@ -746,7 +759,6 @@ public void evaluate() throws Throwable {
                 FlowExecution exec = run.getExecution();
                 Assert.assertTrue(((CpsFlowExecution) exec).isResumeBlocked());
                 if (exec instanceof CpsFlowExecution) {
-                    ((CpsFlowExecution) exec).waitForSuspension(); // till done writing head node ID into build.xml
                     assert ((CpsFlowExecution) exec).getStorage().isPersistedFully();
                 }
                 Assert.assertFalse(((CpsFlowExecution) exec).getProgramDataFile().exists());
@@ -761,7 +773,6 @@ public void evaluate() throws Throwable {
             public void evaluate() throws Throwable {
                 WorkflowRun run = story.j.jenkins.getItemByFullName(jobName, WorkflowJob.class).getLastBuild();
                 verifyFailedCleanly(story.j.jenkins, run);
-                assertIncludesNodes(nodesOut, run);
             }
         });
     }
@@ -779,7 +790,6 @@ public void evaluate() throws Throwable {
                 WorkflowRun run = createAndRunSleeperJob(story.j.jenkins, jobName, FlowDurabilityHint.MAX_SURVIVABILITY, false);
                 FlowExecution exec = run.getExecution();
                 if (exec instanceof CpsFlowExecution) {
-                    ((CpsFlowExecution) exec).waitForSuspension(); // till done writing head node ID into build.xml
                     assert ((CpsFlowExecution) exec).getStorage().isPersistedFully(); // single node xmls written
                 }
                 nodesOut.addAll(new DepthFirstScanner().allNodes(run.getExecution()));
@@ -793,7 +803,6 @@ public void evaluate() throws Throwable {
             public void evaluate() throws Throwable {
                 WorkflowRun run = story.j.jenkins.getItemByFullName(jobName, WorkflowJob.class).getLastBuild();
                 verifyFailedCleanly(story.j.jenkins, run);
-                assertIncludesNodes(nodesOut, run);
             }
         });
     }