new-integration-tests/src/test/java/oracle/weblogic/kubernetes/utils/CommonTestUtils.java
public static void createJobAndWaitUntilComplete(V1Job jobBody, String namespace) {
    LoggingFacade logger = getLogger();
    String jobName = assertDoesNotThrow(() -> createNamespacedJob(jobBody), "createNamespacedJob failed");

    logger.info("Checking if the job {0} completed in namespace {1}", jobName, namespace);
    withStandardRetryPolicy
        .conditionEvaluationListener(
            condition -> logger.info("Waiting for job {0} to be completed in namespace {1} "
                    + "(elapsed time {2} ms, remaining time {3} ms)",
                jobName,
                namespace,
                condition.getElapsedTimeInMS(),
                condition.getRemainingTimeInMS()))
        .until(jobCompleted(jobName, null, namespace));
  }
/**
   * Create a job in the specified namespace and wait until it completes.
   *
   * @param jobBody V1Job object to create in the specified namespace
   * @param namespace the namespace in which the job will be created
   */
Create a job in the specified namespace and wait until it completes.
@param jobBody V1Job object to create in the specified namespace
@param namespace the namespace in which the job will be created
Create a job in the specified namespace and wait until it completes . @param jobBody V1Job object to create in the specified namespace @param namespace the namespace in which the job will be created
public static void createJobAndWaitUntilComplete(V1Job jobBody, String namespace) {
    LoggingFacade logger = getLogger();
    String jobName = assertDoesNotThrow(() -> createNamespacedJob(jobBody), "createNamespacedJob failed");
    logger.info("Checking if the job {0} completed in namespace {1}", jobName, namespace);
    withStandardRetryPolicy
        .conditionEvaluationListener(
            condition -> logger.info("Waiting for job {0} to be completed in namespace {1} "
                    + "(elapsed time {2} ms, remaining time {3} ms)",
                jobName,
                namespace,
                condition.getElapsedTimeInMS(),
                condition.getRemainingTimeInMS()))
        .until(jobCompleted(jobName, null, namespace));
  }
public static void createJobAndWaitUntilComplete ( V1Job jobBody , String namespace ) { LoggingFacade logger = getLogger ( ) ; String jobName = assertDoesNotThrow ( ( ) -> createNamespacedJob ( jobBody ) , "createNamespacedJob failed" ) ; logger . info ( "Checking if the job {0} completed in namespace {1}" , jobName , namespace ) ; withStandardRetryPolicy . conditionEvaluationListener ( condition -> logger . info ( "Waiting for job {0} to be completed in namespace {1} " + "(elapsed time {2} ms, remaining time {3} ms)" , jobName , namespace , condition . getElapsedTimeInMS ( ) , condition . getRemainingTimeInMS ( ) ) ) . until ( jobCompleted ( jobName , null , namespace ) ) ; }
Create a job in the specified namespace and wait until it completes.
Create a job in the specified namespace and wait until it completes .