in o2a/mappers/pig_mapper.py [0:0]
def to_tasks_and_relations(self):
action_task = Task(
task_id=self.name,
template_name="pig.tpl",
template_params=dict(
props=self.props,
params_dict=self.params_dict,
script_file_name=self.script_file_name,
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