Skip to content

Commit f47a826

Browse files
committed
refactor: inline method
1 parent c29c650 commit f47a826

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/CustomResourceEventSource.java

+5-6
Original file line numberDiff line numberDiff line change
@@ -155,15 +155,14 @@ private boolean skipBecauseOfGeneration(T customResource) {
155155
if (customResource.isMarkedForDeletion()) {
156156
return false;
157157
}
158-
return !hasGenerationAlreadyBeenProcessed(customResource);
159-
}
160158

161-
private boolean hasGenerationAlreadyBeenProcessed(T resource) {
162-
Long lastGeneration = lastGenerationProcessedSuccessfully.get(resource.getMetadata().getUid());
159+
// only proceed if we haven't already seen this custom resource generation
160+
Long lastGeneration =
161+
lastGenerationProcessedSuccessfully.get(customResource.getMetadata().getUid());
163162
if (lastGeneration == null) {
164-
return true;
163+
return false;
165164
} else {
166-
return resource.getMetadata().getGeneration() > lastGeneration;
165+
return customResource.getMetadata().getGeneration() <= lastGeneration;
167166
}
168167
}
169168

0 commit comments

Comments
 (0)