Pipeline Dependents

gistfile1.txt

class EnterTheCar(base_handler.PipelineBase):
    def run(self, kid1, kid2):
        return "%s %s" % (kid1, kid2)


class Child(base_handler.PipelineBase):
    def run(self):
        return 'Are we there yet?'


class Father(base_handler.PipelineBase):
    def run(self):
        bob = yield Child()
        kyle = yield Child()
        yield EnterTheCar(bob, kyle)


class MainHandler(webapp2.RequestHandler):
    def get(self):
        incoming = Father()
        incoming.start()
        path = incoming.base_path + "/status?root=" + incoming.pipeline_id
        self.redirect(path)

app = webapp2.WSGIApplication([
    ('/', MainHandler)
], debug=True)