code: @VisibleForTesting
    void tryCleanupPods() {
      var pods = client.pods().list().getItems();
      pods.stream()
          .map(pod -> runAsync(guard(() -> tryCleanupPod(pod)), executor))
          .collect(toList())
          .forEach(CompletableFuture::join);
      tracer.getCurrentSpan().addAnnotation("processed",
          Map.of("pods", AttributeValue.longAttributeValue(pods.size())));
  
    }
docs: Deletes stale workflow instance execution pods.