@Test
public void testRecheckShouldFinishWithoutActionIfConflictWasSolved() throws IgniteCheckedException {

    UUID nodeId1 = UUID.randomUUID();
    UUID nodeId2 = UUID.randomUUID();
    MockedProcessor processor = MockedProcessor.create(false, Arrays.asList(nodeId1, nodeId2));
    KeyCacheObjectImpl key = new KeyCacheObjectImpl(1, null, PARTITION_ID);
    GridCacheVersion ver = new GridCacheVersion(1, 0, 0, 0);
    Map<KeyCacheObject, Map<UUID, GridCacheVersion>> batchRes = new HashMap<>();
    Map<UUID, GridCacheVersion> oldKeys = new HashMap<>();
    oldKeys.put(nodeId1, ver);
    oldKeys.put(nodeId2, ver);
    batchRes.put(key, oldKeys);
    Map<KeyCacheObject, Map<UUID, VersionedValue>> sameRes = new HashMap<>();
    Map<UUID, VersionedValue> actualKey = new HashMap<>();
    actualKey.put(nodeId1, new VersionedValue(null, ver, 1, 1));
    actualKey.put(nodeId2, new VersionedValue(null, ver, 1, 1));
    sameRes.put(key, actualKey);
    processor.addTask(new Recheck(ReconciliationExecutionContext.IGNORE_JOB_PERMITS_SESSION_ID, UUID.randomUUID(),
        batchRes, DEFAULT_CACHE, PARTITION_ID, 0, 0))
        .whereResult(CollectPartitionKeysByRecheckRequestTask.class, new ExecutionResult<>(sameRes))
        .execute();
    processor.verify(never()).schedule(any());
    processor.verify(never()).schedule(any(), anyInt(), any());
    processor.verify(never()).scheduleHighPriority(any());
}