@Test(expected = TestException.class)
public void testCanCommitWithFailedCohortFuture() throws Exception {

    List<CohortInfo> cohorts = Arrays.asList(
            newCohortInfo(new CohortActor.Builder(tx)),
            newCohortInfoWithFailedFuture(new TestException()),
            newCohortInfo(new CohortActor.Builder(tx)));
    ThreePhaseCommitCohortProxy proxy = new ThreePhaseCommitCohortProxy(actorUtils, cohorts, tx);
    propagateExecutionExceptionCause(proxy.canCommit());
}