@Test
public void testReadThrottlingWhenShardNotFound() {

    completeOperation(transactionProxy -> {
        doReturn(incompleteFuture()).when(mockActorContext).executeOperationAsync(
                any(ActorSelection.class), eqReadData());
        transactionProxy.read(TestModel.TEST_PATH);
        transactionProxy.read(TestModel.TEST_PATH);
    }, false);
}