in o2a/mappers/shell_mapper.py [0:0]
def to_tasks_and_relations(self):
action_task = Task(
task_id=self.name,
template_name="shell.tpl",
template_params=dict(
pig_command=self.pig_command, action_node_properties=self.props.action_node_properties
),
)
tasks = [action_task]
relations: List[Relation] = []
prepare_task = self.prepare_extension.get_prepare_task()
if prepare_task:
tasks, relations = self.prepend_task(prepare_task, tasks, relations)
return tasks, relations