Skip to content

Commit 3785ea1

Browse files
committed
rebase next, test fix
1 parent 4c5831a commit 3785ea1

File tree

1 file changed

+3
-9
lines changed

1 file changed

+3
-9
lines changed

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

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -433,22 +433,16 @@ void executionOfReconciliationShouldNotStartIfProcessorStopped() throws Interrup
433433

434434
var execManager = new ExecutorServiceManager(
435435
ConfigurationService.overrideCurrent(new BaseConfigurationService(),
436-
o -> o.withConcurrentReconciliationThreads(1)));
436+
o -> { o.withConcurrentReconciliationThreads(1);
437+
o.withMinConcurrentReconciliationThreads(1);
438+
}));
437439
execManager.init();
438440
eventProcessor =
439441
spy(new EventProcessor(controllerConfiguration(null, rateLimiterMock),
440442
reconciliationDispatcherMock,
441443
eventSourceManagerMock, null,execManager));
442444
eventProcessor.start();
443445

444-
// one event will lock the thread / executor
445-
ConfigurationServiceProvider.overrideCurrent(o -> {
446-
o.withConcurrentReconciliationThreads(1);
447-
o.withMinConcurrentReconciliationThreads(1);
448-
});
449-
ExecutorServiceManager.reset();
450-
eventProcessor.start();
451-
452446
eventProcessor.handleEvent(prepareCREvent());
453447
eventProcessor.handleEvent(prepareCREvent());
454448
eventProcessor.stop();

0 commit comments

Comments
 (0)