Skip to content

Commit 35fb91e

Browse files
committed
fixes
Signed-off-by: Attila Mészáros <[email protected]>
1 parent d17cb50 commit 35fb91e

File tree

2 files changed

+7
-9
lines changed

2 files changed

+7
-9
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -403,7 +403,7 @@ private P updateCustomResourceWithFinalizer(P resourceForExecution, P originalRe
403403
resourceForExecution,
404404
originalResource,
405405
r -> r.addFinalizer(configuration().getFinalizerName()),
406-
false);
406+
true);
407407
}
408408

409409
private P patchResource(Context<P> context, P resource, P originalResource) {

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

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -164,19 +164,17 @@ void addFinalizerOnNewResource() {
164164

165165
@Test
166166
void addFinalizerOnNewResourceWithoutSSA() {
167-
initConfigService(false);
167+
initConfigService(false, false);
168168
final ReconciliationDispatcher<TestCustomResource> dispatcher =
169169
init(testCustomResource, reconciler, null, customResourceFacade, true);
170170

171171
assertFalse(testCustomResource.hasFinalizer(DEFAULT_FINALIZER));
172172
dispatcher.handleExecution(executionScopeWithCREvent(testCustomResource));
173173
verify(reconciler, never()).reconcile(ArgumentMatchers.eq(testCustomResource), any());
174174
verify(customResourceFacade, times(1))
175-
.patchResource(
176-
any(),
177-
argThat(testCustomResource -> testCustomResource.hasFinalizer(DEFAULT_FINALIZER)),
178-
any());
179-
assertThat(testCustomResource.hasFinalizer(DEFAULT_FINALIZER)).isTrue();
175+
.patchResourceWithoutSSA(
176+
argThat(cr -> cr.hasFinalizer(DEFAULT_FINALIZER)),
177+
argThat(cr -> !cr.hasFinalizer(DEFAULT_FINALIZER)));
180178
}
181179

182180
@Test
@@ -668,7 +666,7 @@ void retriesAddingFinalizerWithoutSSA() {
668666

669667
removeFinalizers(testCustomResource);
670668
reconciler.reconcile = (r, c) -> UpdateControl.noUpdate();
671-
when(customResourceFacade.patchResource(any(), any(), any()))
669+
when(customResourceFacade.patchResourceWithoutSSA(any(), any()))
672670
.thenThrow(new KubernetesClientException(null, 409, null))
673671
.thenReturn(testCustomResource);
674672
when(customResourceFacade.getResource(any(), any()))
@@ -681,7 +679,7 @@ void retriesAddingFinalizerWithoutSSA() {
681679

682680
reconciliationDispatcher.handleExecution(executionScopeWithCREvent(testCustomResource));
683681

684-
verify(customResourceFacade, times(2)).patchResource(any(), any(), any());
682+
verify(customResourceFacade, times(2)).patchResourceWithoutSSA(any(), any());
685683
}
686684

687685
@Test

0 commit comments

Comments
 (0)