wip

csviri · csviri · commit e4ececf5787e · 2026-03-08T14:41:51.000+01:00
Signed-off-by: Attila Mészáros &lt;a_meszaros@apple.com&gt;
diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java
@@ -153,6 +153,7 @@ private synchronized EventHandling onEvent(
         result = EventHandling.OBSOLETE;
       }
     }
+    checkStaleResources();
     var ed = activeUpdates.get(resourceId);
     if (ed != null && result != EventHandling.OBSOLETE) {
       log.debug("Setting last event for id: {} delete: {}", resourceId, delete);
@@ -167,6 +168,7 @@ private synchronized EventHandling onEvent(
   }
 
   private void checkStaleResources() {
+    // todo add only once within an interval check
     CompletableFuture.runAsync(
         () -> {
           var longLatest = Long.parseLong(latestResourceVersion);

Original file line number	Diff line number	Diff line change
`@@ -153,6 +153,7 @@ private synchronized EventHandling onEvent(`
`153`	`153`	`result = EventHandling.OBSOLETE;`
`154`	`154`	`}`
`155`	`155`	`}`
	`156`	`+ checkStaleResources();`
`156`	`157`	`var ed = activeUpdates.get(resourceId);`
`157`	`158`	`if (ed != null && result != EventHandling.OBSOLETE) {`
`158`	`159`	`log.debug("Setting last event for id: {} delete: {}", resourceId, delete);`
`@@ -167,6 +168,7 @@ private synchronized EventHandling onEvent(`
`167`	`168`	`}`
`168`	`169`
`169`	`170`	`private void checkStaleResources() {`
	`171`	`+ // todo add only once within an interval check`
`170`	`172`	`CompletableFuture.runAsync(`
`171`	`173`	`() -> {`
`172`	`174`	`var longLatest = Long.parseLong(latestResourceVersion);`