def forwards(self, orm):
        for design in orm.OozieDesign.objects.all():
            action = convert_jobsub_design(design)

            if not action:
                raise RuntimeError(_("Cannot convert %s design into an Oozie action.") % design.name)

            # User is guaranteed to exist since this executes for upgrades only.
            workflow = Workflow.objects.new_workflow(User.objects.get(id=design.owner.pk))
            workflow.name = action.name
            workflow.description = design.description
            # Inform oozie to not manage this workflow.
            workflow.managed = False
            workflow.save()

            workflow.start.workflow = workflow
            workflow.start.save()
            workflow.start = Start.objects.get(id=workflow.start.id)

            workflow.end.workflow = workflow
            workflow.end.save()
            workflow.end = End.objects.get(id=workflow.end.id)

            Kill.objects.create(name='kill', workflow=workflow, node_type=Kill.node_type)

            action.workflow = workflow
            action.save()

            workflow.start.add_node(action)
            action.add_node(workflow.end)

            workflow.save()
:reference: https://dev.twitter.com/docs/api/1.1/get/geo/search
dataset/ETHPy150Open cloudera/hue/apps/jobsub/src/jobsub/migrations/0005_unify_with_oozie.py/Migration.forwards--crossover with--dataset/ETHPy150Open tweepy/tweepy/tweepy/api.py/API.geo_search