Skip to content

Commit e4dcde2

Browse files
committed
Test fix
Signed-off-by: Attila Mészáros <[email protected]>
1 parent fa5642f commit e4dcde2

File tree

3 files changed

+17
-18
lines changed

3 files changed

+17
-18
lines changed

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

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ class ReconciliationDispatcher<P extends HasMetadata> {
4949
this.controller = controller;
5050
this.customResourceFacade = customResourceFacade;
5151
final var configuration = controller.getConfiguration();
52-
this.cloner = configuration.getConfigurationService().getResourceCloner();
52+
this.cloner = configuration.getConfigurationService().getResourceCloner();
5353

5454
var retry = configuration.getRetry();
5555
retryConfigurationHasZeroAttempts = retry == null || retry.initExecution().isLastAttempt();
@@ -402,22 +402,22 @@ public R patchResource(R resource, R originalResource) {
402402

403403
public R patchStatus(R resource, R originalResource) {
404404
log.trace("Patching status for resource: {} with ssa: {}", resource, useSSA);
405-
if (useSSA) {
406-
var managedFields = resource.getMetadata().getManagedFields();
407-
try {
408-
resource.getMetadata().setManagedFields(null);
409-
var res = resource(resource);
410-
return res.subresource("status").patch(new PatchContext.Builder()
411-
.withFieldManager(fieldManager)
412-
.withForce(true)
413-
.withPatchType(PatchType.SERVER_SIDE_APPLY)
414-
.build());
415-
} finally {
416-
resource.getMetadata().setManagedFields(managedFields);
417-
}
418-
} else {
419-
return editStatus(resource, originalResource);
405+
if (useSSA) {
406+
var managedFields = resource.getMetadata().getManagedFields();
407+
try {
408+
resource.getMetadata().setManagedFields(null);
409+
var res = resource(resource);
410+
return res.subresource("status").patch(new PatchContext.Builder()
411+
.withFieldManager(fieldManager)
412+
.withForce(true)
413+
.withPatchType(PatchType.SERVER_SIDE_APPLY)
414+
.build());
415+
} finally {
416+
resource.getMetadata().setManagedFields(managedFields);
420417
}
418+
} else {
419+
return editStatus(resource, originalResource);
420+
}
421421
}
422422

423423
private R editStatus(R resource, R originalResource) {

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuspatchnonlocking/StatusPatchLockingReconciler.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import java.util.concurrent.atomic.AtomicInteger;
44

5-
import io.fabric8.kubernetes.api.model.HasMetadata;
65
import io.javaoperatorsdk.operator.api.reconciler.Context;
76
import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
87
import io.javaoperatorsdk.operator.api.reconciler.Reconciler;

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuspatchnonlocking/StatusPatchNotLockingForNonSSAIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ class StatusPatchNotLockingForNonSSAIT {
2121
@RegisterExtension
2222
LocallyRunOperatorExtension operator =
2323
LocallyRunOperatorExtension.builder().withReconciler(StatusPatchLockingReconciler.class)
24-
.withConfigurationService(o->o.withUseSSAToPatchPrimaryResource(false))
24+
.withConfigurationService(o -> o.withUseSSAToPatchPrimaryResource(false))
2525
.build();
2626

2727
@Test

0 commit comments

Comments
 (0)