import static java.util.concurrent.TimeUnit.NANOSECONDS;
@ThreadSafe
public class PipelineContext
{
private final TaskContext taskContext;
<BUG>private final Executor executor;
private final boolean inputPipeline;</BUG>
private final boolean outputPipeline;
private final List<DriverContext> drivers = new CopyOnWriteArrayList<>();
private final AtomicInteger completedDrivers = new AtomicInteger();

import static java.util.concurrent.TimeUnit.NANOSECONDS;
@ThreadSafe
public class PipelineContext
{
private final TaskContext taskContext;
private final Executor executor;
private final int pipelineId;
private final boolean inputPipeline;
private final boolean outputPipeline;
private final List<DriverContext> drivers = new CopyOnWriteArrayList<>();
private final AtomicInteger completedDrivers = new AtomicInteger();
