def apply_task_to_dag()

in liminal/runners/airflow/tasks/job_end.py [0:0]

• 12 lines of code
• 2 McCabe index (conditional complexity)

    def apply_task_to_dag(self):
        job_end_task = JobEndOperator(
            task_id='end',
            namespace=self.metrics_namespace,
            application_name=self.pipeline_config['pipeline'],
            backends=self.metrics_backends,
            dag=self.dag,
            trigger_rule=self.trigger_rule,
        )

        if self.parent:
            self.parent.set_downstream(job_end_task)

        return job_end_task