Pipeline Simple

gistfile1.txt

class GrandGrandSon(base_handler.PipelineBase):
    def run(self):
        return 'big family'


class GrandSon(base_handler.PipelineBase):
    def run(self):
        yield GrandGrandSon()


class Child(base_handler.PipelineBase):
    def run(self):
        yield GrandSon()


class Father(base_handler.PipelineBase):
    def run(self):
        yield Child()


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)