From de3f1a25ed076ce66a24e6e5346d9579a8e94c24 Mon Sep 17 00:00:00 2001 From: phi Date: Tue, 20 Aug 2024 21:12:02 +0900 Subject: [PATCH] docs: add comments --- airflow/decorators/base.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/airflow/decorators/base.py b/airflow/decorators/base.py index 208fa7d6bccd27..a238b3ac9d7b3c 100644 --- a/airflow/decorators/base.py +++ b/airflow/decorators/base.py @@ -444,12 +444,12 @@ def _expand(self, expand_input: ExpandInput, *, strict: bool) -> XComArg: } base_signature = inspect.signature(BaseOperator) ignore = { - "default_args", - "kwargs", - "do_xcom_push", - "multiple_outputs", - "params", - "task_concurrency", + "default_args", # This is target we are working on now. + "kwargs", # A common name for a keyword argument. + "do_xcom_push", # In the same boat as `multiple_outputs` + "multiple_outputs", # We will use `self.multiple_outputs` instead. + "params", # Already handled above `partial_params`. + "task_concurrency", # Deprecated(replaced by `max_active_tis_per_dag`). } partial_keys = set(base_signature.parameters) - ignore partial_kwargs.update({key: value for key, value in default_args.items() if key in partial_keys})