control-service: better error message (#2094)

vmware · May 19, 2023 · 646a634 · 646a634
1 parent a256ba9
commit 646a634
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/...ntegration-test/java/com/vmware/taurus/datajobs/it/common/DataJobDeploymentExtension.java b/...ntegration-test/java/com/vmware/taurus/datajobs/it/common/DataJobDeploymentExtension.java
@@ -178,10 +178,26 @@ public void beforeEach(ExtensionContext context) throws Exception {
           .andExpect(status().isAccepted())
           .andReturn();
 
+      await()
+          .atMost(120, TimeUnit.SECONDS)
+          .with()
+          .pollDelay(20, TimeUnit.SECONDS)
+          .pollInterval(2, TimeUnit.SECONDS)
+          .failFast(
+              () -> {
+                if (dataJobsKubernetesService
+                    .getPod("builder-" + jobName)
+                    .map(a -> a.getStatus().getPhase().equals("Failed"))
+                    .orElse(false)) {
+                  throw new Exception(dataJobsKubernetesService.getPodLogs("builder-" + jobName));
+                }
+              })
+          .until(() -> dataJobsKubernetesService.getPod("builder-" + jobName).isEmpty());
+
       // Verify that the job deployment was created
       String jobDeploymentName = JobImageDeployer.getCronJobName(jobName);
       await()
-          .atMost(360, TimeUnit.SECONDS)
+          .atMost(240, TimeUnit.SECONDS)
           .with()
           .pollInterval(10, TimeUnit.SECONDS)
           .until(() -> dataJobsKubernetesService.readCronJob(jobDeploymentName).isPresent());