Skip to content

Commit 45d4d09

Browse files
committed
experiment
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 3df2a4d commit 45d4d09

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public synchronized void putResource(T newResource, String previousResourceVersi
9393
}
9494
var resourceId = ResourceID.fromResource(newResource);
9595
var cachedResource = managedInformerEventSource.get(resourceId).orElse(null);
96-
96+
temporalPrimaryToSecondaryIndex.explicitAddOrUpdate(newResource);
9797
boolean moveAhead = false;
9898
if (previousResourceVersion == null && cachedResource == null) {
9999
if (tombstones.contains(newResource.getMetadata().getUid())) {
@@ -119,7 +119,7 @@ public synchronized void putResource(T newResource, String previousResourceVersi
119119
"Temporarily moving ahead to target version {} for resource id: {}",
120120
newResource.getMetadata().getResourceVersion(),
121121
resourceId);
122-
temporalPrimaryToSecondaryIndex.explicitAddOrUpdate(newResource);
122+
123123
cache.put(resourceId, newResource);
124124
} else if (cache.remove(resourceId) != null) {
125125
log.debug("Removed an obsolete resource from cache for id: {}", resourceId);

0 commit comments

Comments
 (0)