diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSource.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSource.java index ad688599db..7b02f7e43e 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSource.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSource.java @@ -149,7 +149,7 @@ public void run() { var primary = resourceCache.get(primaryID); if (primary.isEmpty()) { log.warn("No resource in cache for resource ID: {}", primaryID); - // no new execution is scheduled in this case, a on delete event should be received shortly + // no new execution is scheduled in this case, an on delete event should be received shortly } else { var actualResources = primary.map(p -> getAndCacheResource(p, false)); scheduleNextExecution(primary.get(), actualResources.orElse(null)); diff --git a/operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSourceTest.java b/operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSourceTest.java index 727b60ed9b..02f173da2b 100644 --- a/operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSourceTest.java +++ b/operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSourceTest.java @@ -172,11 +172,12 @@ void deleteEventCancelsTheScheduling() { .pollInterval(Duration.ofMillis(20)) .untilAsserted(() -> verify(supplier,times(1)).fetchResources(any())); + when(resourceCache.get(any())).thenReturn(Optional.empty()); source.onResourceDeleted(testCustomResource); - // check if not called again. - await().pollDelay(Duration.ofMillis(PERIOD)) - .atMost(Duration.ofMillis((2* PERIOD))) + // check if not called again + await().pollDelay(Duration.ofMillis(2*PERIOD)) + .atMost(Duration.ofMillis((4* PERIOD))) .untilAsserted(() -> verify(supplier,times(1)).fetchResources(any())); }