presto-main/src/main/java/io/prestosql/operator/TaskOutputOperator.java/TaskOutputOperator/needsInput
class TaskOutputOperator:    @Override
    public boolean needsInput()
    {
        return !finished && isBlocked().isDone();
    }