Skip to content

Commit c713574

Browse files
committed
Revert "feature: update observed generation on updateResource"
This reverts commit 07f3053.
1 parent c46bb6c commit c713574

File tree

2 files changed

+1
-24
lines changed

2 files changed

+1
-24
lines changed

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -157,9 +157,6 @@ private PostExecutionControl<R> reconcileExecution(ExecutionScope<R> executionSc
157157
updatedCustomResource = updateStatusGenerationAware(updateControl.getResource());
158158
} else if (updateControl.isUpdateResource()) {
159159
updatedCustomResource = updateCustomResource(updateControl.getResource());
160-
if (shouldUpdateObservedGenerationAutomatically(updatedCustomResource)) {
161-
updatedCustomResource = updateStatusGenerationAware(originalResource);
162-
}
163160
} else if (updateControl.isNoUpdate()
164161
&& shouldUpdateObservedGenerationAutomatically(resourceForExecution)) {
165162
updatedCustomResource = updateStatusGenerationAware(originalResource);

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/ReconciliationDispatcherTest.java

Lines changed: 1 addition & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ private <R extends HasMetadata> ReconciliationDispatcher<R> init(R customResourc
6161
.thenReturn(UpdateControl.updateResource(customResource));
6262
when(reconciler.cleanup(eq(customResource), any()))
6363
.thenReturn(DeleteControl.defaultDelete());
64+
when(customResourceFacade.replaceWithLock(any())).thenReturn(null);
6465
Controller<R> controller =
6566
new Controller<>(reconciler, configuration, null);
6667

@@ -344,27 +345,6 @@ void updatesObservedGenerationOnNoUpdateUpdateControl() {
344345
.isEqualTo(1L);
345346
}
346347

347-
@Test
348-
void updateObservedGenerationOnCustomResourceUpdate() {
349-
var observedGenResource = createObservedGenCustomResource();
350-
351-
Reconciler<ObservedGenCustomResource> reconciler = mock(Reconciler.class);
352-
ControllerConfiguration<ObservedGenCustomResource> config =
353-
mock(ControllerConfiguration.class);
354-
CustomResourceFacade<ObservedGenCustomResource> facade = mock(CustomResourceFacade.class);
355-
when(config.isGenerationAware()).thenReturn(true);
356-
when(reconciler.reconcile(any(), any()))
357-
.thenReturn(UpdateControl.updateResource(observedGenResource));
358-
when(facade.replaceWithLock(any())).thenReturn(observedGenResource);
359-
when(facade.updateStatus(observedGenResource)).thenReturn(observedGenResource);
360-
var dispatcher = init(observedGenResource, reconciler, config, facade);
361-
362-
PostExecutionControl<ObservedGenCustomResource> control = dispatcher.handleExecution(
363-
executionScopeWithCREvent(observedGenResource));
364-
assertThat(control.getUpdatedCustomResource().get().getStatus().getObservedGeneration())
365-
.isEqualTo(1L);
366-
}
367-
368348
@Test
369349
void callErrorStatusHandlerIfImplemented() {
370350
testCustomResource.addFinalizer(DEFAULT_FINALIZER);

0 commit comments

Comments
 (0)