Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 7d2a5bf

Browse files
committedMar 10, 2025
wip
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 1649e28 commit 7d2a5bf

File tree

1 file changed

+2
-31
lines changed

1 file changed

+2
-31
lines changed
 

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/KubernetesResourceDeletedCondition.java

+2-31
Original file line numberDiff line numberDiff line change
@@ -7,44 +7,15 @@
77
import io.javaoperatorsdk.operator.api.reconciler.Context;
88
import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
99

10-
/**
11-
* A condition implementation meant to be used as a delete post-condition on Kubernetes dependent
12-
* resources to prevent the workflow from proceeding until the associated resource is actually
13-
* deleted from the server (or, at least, doesn't have any finalizers anymore). This is needed in
14-
* cases where a cleaning process depends on resources being actually removed from the server
15-
* because, by default, workflows simply request the deletion but do NOT wait for the resources to
16-
* be actually deleted.
17-
*/
18-
public class KubernetesResourceDeletedCondition implements Condition<HasMetadata, HasMetadata> {
1910

20-
private static final Logger logger =
21-
LoggerFactory.getLogger(KubernetesResourceDeletedCondition.class);
11+
public class KubernetesResourceDeletedCondition implements Condition<HasMetadata, HasMetadata> {
2212

2313
@Override
2414
public boolean isMet(
2515
DependentResource<HasMetadata, HasMetadata> dependentResource,
2616
HasMetadata primary,
2717
Context<HasMetadata> context) {
2818
var optionalResource = dependentResource.getSecondaryResource(primary, context);
29-
if (optionalResource.isEmpty()) {
30-
if (logger.isDebugEnabled()) {
31-
logger.debug(
32-
"Resource not found in cache, considering it deleted. "
33-
+ "Dependent resource name: {}, primary resource name: {}",
34-
dependentResource.name(),
35-
primary.getMetadata().getName());
36-
}
37-
return true;
38-
} else {
39-
var finalizers = optionalResource.orElseThrow().getMetadata().getFinalizers();
40-
if (logger.isDebugEnabled()) {
41-
logger.debug(
42-
"finalizers: {}, dependent resource name: {}, primary resource name: {}\"",
43-
finalizers,
44-
dependentResource.name(),
45-
primary.getMetadata().getName());
46-
}
47-
return finalizers.isEmpty();
48-
}
19+
return optionalResource.isEmpty();
4920
}
5021
}

0 commit comments

Comments
 (0)
Please sign in to comment.