def execute(self):
        type_ = 'Job' if 'Job' in self.handler.input else 'Task'
        parallel = self.handler.input[type_].get('parallel', False)
        for i, child in enumerate(self.handler.input[type_]['children']):
            priority = get_priority(self.handler.input, self.handler.priority, i)
            if 'Task' in child:
                self.execute_task(child, priority)
            elif 'Action' in child and not child['Action']['_whenerror']:
                self.execute_action(child, priority)

            if not parallel:
                self.wait()
        if parallel:
            for child in self.handler.input[type_]['children']:
                self.wait()
Execute input of SWF workflow.
dataset/ETHPy150Open KKBOX/mass/mass/scheduler/swf/__init__.py/SWFDecider.execute