Skip to content

Commit 8bd3428

Browse files
metacosmcsviri
authored andcommitted
fix: proper cast
1 parent bc53528 commit 8bd3428

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ void scheduleTimedEventIfInstructedByPostExecutionControl() {
215215
eventProcessor.handleEvent(prepareCREvent());
216216

217217
verify(retryTimerEventSourceMock, timeout(SEPARATE_EXECUTION_TIMEOUT).times(1))
218-
.scheduleOnce((HasMetadata) any(), eq(testDelay));
218+
.scheduleOnce((ResourceID) any(), eq(testDelay));
219219
}
220220

221221
@Test
@@ -231,7 +231,7 @@ void reScheduleOnlyIfNotExecutedEventsReceivedMeanwhile() throws InterruptedExce
231231

232232
verify(retryTimerEventSourceMock,
233233
after((long) (FAKE_CONTROLLER_EXECUTION_DURATION * 1.5)).times(0))
234-
.scheduleOnce((HasMetadata) any(), eq(testDelay));
234+
.scheduleOnce((ResourceID) any(), eq(testDelay));
235235
}
236236

237237
@Test
@@ -358,10 +358,10 @@ void rateLimitsReconciliationSubmission() {
358358
eventProcessor.handleEvent(event);
359359
verify(reconciliationDispatcherMock, after(FAKE_CONTROLLER_EXECUTION_DURATION).times(1))
360360
.handleExecution(any());
361-
verify(retryTimerEventSourceMock, times(0)).scheduleOnce((HasMetadata) any(), anyLong());
361+
verify(retryTimerEventSourceMock, times(0)).scheduleOnce((ResourceID) any(), anyLong());
362362

363363
eventProcessor.handleEvent(event);
364-
verify(retryTimerEventSourceMock, times(1)).scheduleOnce((HasMetadata) any(), anyLong());
364+
verify(retryTimerEventSourceMock, times(1)).scheduleOnce((ResourceID) any(), anyLong());
365365
}
366366

367367
private ResourceID eventAlreadyUnderProcessing() {

0 commit comments

Comments
 (0)