def to_tasks_and_relations()

in o2a/mappers/hive_mapper.py [0:0]

• 19 lines of code
• 3 McCabe index (conditional complexity)

    def to_tasks_and_relations(self):
        action_task = Task(
            task_id=self.name,
            template_name="hive.tpl",
            template_params=dict(
                query_obj=dict(queries=[self.query]) if self.query else None,
                script=self.script,
                props=self.props,
                archives=self.hdfs_archives,
                files=self.hdfs_files,
                variables=self.variables,
            ),
        )
        tasks = [action_task]
        relations = []
        prepare_task = self.prepare_extension.get_prepare_task()
        if prepare_task:
            tasks, relations = self.prepend_task(prepare_task, tasks, relations)

        return tasks, relations