public static Optional areOperatorsStarted()

in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/ProbeUtil.java [79:94]

• 16 lines of code
• 4 McCabe index (conditional complexity)

  public static Optional<Boolean> areOperatorsStarted(List<Operator> operators) {
    return operators.stream()
        .map(
            operator -> {
              RuntimeInfo runtimeInfo = operator.getRuntimeInfo();
              if (runtimeInfo != null) {
                if (!operator.getRuntimeInfo().isStarted()) {
                  log.error("Operator is not running");
                  return false;
                }
                return true;
              }
              return false;
            })
        .reduce((a, b) -> a && b);
  }