@Test
public void testExecute() throws Exception
{

    doReturn( true ).doReturn( false ).when( peerTaskResult ).hasSucceeded();
    step.execute();
    step.execute();
    verify( peerUtil, times( 2 ) ).executeParallel();
}