Closed szczeles closed 3 years ago
Staring with Airflow 2.1.1, default DAG args are passed as additional parameter to operators (https://github.com/apache/airflow/blob/2.1.1/airflow/models/baseoperator.py#L180), so we need to allow **kwargs in our operators (and pass it downstream)
**kwargs
Keep in mind:
Staring with Airflow 2.1.1, default DAG args are passed as additional parameter to operators (https://github.com/apache/airflow/blob/2.1.1/airflow/models/baseoperator.py#L180), so we need to allow
**kwargsin our operators (and pass it downstream)Keep in mind: