def execute()

in liminal/runners/airflow/operators/job_status_operator.py [0:0]

• 7 lines of code
• 4 McCabe index (conditional complexity)

    def execute(self, context):
        for backend in self.backends:
            if backend in self.report_functions:
                for metric in self.metrics(context):
                    self.report_functions[backend](self, metric)
            else:
                raise AirflowException(f'No such metrics backend: {backend}')