final List<Exception> failures = waitForPipelineReplicaCommands( futures, timeoutInMillis, "resume" );
LOGGER.info( "Replica runners of Pipeline {} are resumed...", id );
runnerStatus = PipelineReplicaRunnerStatus.RUNNING;
return failures;
}
<BUG>public List<Exception> stopPipelineReplicaRunners ( final boolean disableCapacityCheck, final long timeoutInMillis )
{</BUG>
checkState( pipelineStatus == RUNNING || pipelineStatus == COMPLETING || pipelineStatus == COMPLETED,
"cannot stop pipeline %s replica runners since in %s status",
id,

final List<Exception> failures = waitForPipelineReplicaCommands( futures, timeoutInMillis, "resume" );
LOGGER.info( "Replica runners of Pipeline {} are resumed...", id );
runnerStatus = PipelineReplicaRunnerStatus.RUNNING;
return failures;
}
public List<Exception> stopPipelineReplicaRunners ( final long timeoutInMillis )
{
checkState( pipelineStatus == RUNNING || pipelineStatus == COMPLETING || pipelineStatus == COMPLETED,
"cannot stop pipeline %s replica runners since in %s status",
id,
