public static void deleteResourceIfExists()

in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/ReconcilerUtils.java [141:160]

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

  public static <T extends HasMetadata> void deleteResourceIfExists(
      final KubernetesClient client, final T resource, boolean forceDelete) {
    try {
      if (forceDelete) {
        client.resource(resource).withGracePeriod(0L).delete();
      } else {
        client
            .resource(resource)
            .withPropagationPolicy(DeletionPropagation.FOREGROUND)
            .withTimeout(RECONCILER_FOREGROUND_REQUEST_TIMEOUT_SECONDS.getValue(), TimeUnit.SECONDS)
            .delete();
      }
    } catch (KubernetesClientException e) {
      if (e.getCode() == HTTP_NOT_FOUND) {
        log.info("Pod to delete does not exist, proceeding...");
      } else {
        throw e;
      }
    }
  }