I'm used to using the Pipeline API inside the mapreduce library, but now that I'm using just the pipeline library solo I can't get past starting the pipeline. I always get the same error: "Yielded a disallowed value". I tried using the same library from mapreduce to see if the one I downloaded was bugged using and got the same thing... Removed my code and went with the sample code from the "getting started guide":
class AddOne(pipeline.Pipeline):
def run(self, number):
return number + 1
class AddTwo(pipeline.Pipeline):
def run(self, number):
result = yield AddOne(number)
yield AddOne(result)
Started this pipeline and got stuck at the same error:
UnexpectedPipelineError: Yielded a disallowed value: handlers.importpipeline.AddOne(*(15,), **{})
Has anyone been through this?