gistfile1.py

def load_pipeline(cls_path):
    module_path, class_name = ".".join(cls_path.split('.')[:-1]), cls_path.split('.')[-1]
    mod = __import__(module_path, fromlist=[class_name])
    return getattr(mod, class_name)


class TriggerHandler(ApiHandler):

    def get(self):
        id = self.request.get("id")
        path = self.request.get("path")
        args = self.request.get("args")

        method = method.lower()
        assert path

        cls = load_pipeline(path)
        p = cls(*params)
        p.start()

        task_id = id or p.root_pipeline_id

        _TA_Task(
            id=task_id,
            root_pipeline_id=p.root_pipeline_id,
            params={
                "id": id,
                "path": path,
                "params": params
            }
        ).put()

        return self.output({
            "id": task_id
        })