def __init__()

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

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

    def __init__(self, dag, task_config: dict, variables: dict = None, liminal_task_instance=None, **kwargs):
        self.operator_delegate: BaseOperator = kwargs.pop('operator')
        self.liminal_task_instance = liminal_task_instance.serialize() if liminal_task_instance else None
        if variables:
            self.variables = variables.copy()
        else:
            self.variables = {}
        self.task_config = task_config
        super().__init__(task_id=self.operator_delegate.task_id, dag=dag)
        self._LOG = logging.getLogger(self.__class__.__name__)