def execute()

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

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

    def execute(self, context):
        attributes = self._get_operator_delegate_attributes()
        self._LOG.info(f'task_config: {self.task_config}')
        self._LOG.info(f'variables: {self.variables}')
        self.operator_delegate.template_fields = set(list(self.operator_delegate.template_fields) + attributes)
        self.operator_delegate.render_template_fields(context, LiminalEnvironment(self.variables, self.task_config))
        self.operator_delegate.render_template_fields(context)

        if 'ti' in context:
            context['ti'].xcom_push(key="liminal_task_instance", value=self.liminal_task_instance)

        return self.operator_delegate.execute(context)