Preserve the thread's interrupted status when the task completes.

fabric8io · Sep 29, 2020 · f3f4a3a · f3f4a3a
1 parent 2b241ee
commit f3f4a3a
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...nt/dsl/internal/NamespaceVisitFromServerGetWatchDeleteRecreateWaitApplicableListImpl.java b/...nt/dsl/internal/NamespaceVisitFromServerGetWatchDeleteRecreateWaitApplicableListImpl.java
@@ -147,6 +147,13 @@ public List<HasMetadata> waitUntilCondition(Predicate<HasMetadata> condition,
         futures.add(CompletableFuture.supplyAsync(() -> {
           try {
             return h.waitUntilCondition(client, config, meta.getMetadata().getNamespace(), meta, condition, amount, timeUnit);
+          } catch (InterruptedException e) {
+            // Don't forget that this thread was interrupted.
+            Thread.currentThread().interrupt();
+
+            //consider all errors as not ready.
+            logAsNotReady(e, meta);
+            return null;
           } catch (Exception e) {
             //consider all errors as not ready.
             logAsNotReady(e, meta);