Skip to content

Commit

Permalink
docs: add comments
Browse files Browse the repository at this point in the history
  • Loading branch information
phi-friday committed Aug 20, 2024
1 parent 1587f74 commit de3f1a2
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions airflow/decorators/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -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})
Expand Down

0 comments on commit de3f1a2

Please sign in to comment.