I'm not an expert of the Airflow code, but in 1.10.2 I notice the decorator on the __init__ of the BaseOperator named "apply_defaults": https://github.com/apache/airflow/blob/1.10.2/airflow/models.py#L2472
Which is located here: https://github.com/apache/airflow/blob/1.10.2/airflow/utils/decorators.py#L37 Which has the docstring: Function decorator that Looks for an argument named "default_args", and fills the unspecified arguments from it. Damian -----Original Message----- From: Massy Bourennani <[email protected]> Sent: Wednesday, February 19, 2020 10:49 To: [email protected] Subject: How is DAG's default_arg parameter forwarded to operators ? Hello all, I'm searching through the Git repo but I couldn't find the code responsible for forwardings DAG's default_args to DAG's operators. I'm using Airflow 1.10.2 Many thanks, Massy =============================================================================== Please access the attached hyperlink for an important electronic communications disclaimer: http://www.credit-suisse.com/legal/en/disclaimer_email_ib.html ===============================================================================
