diff --git a/airflow/models/mappedoperator.py b/airflow/models/mappedoperator.py index 663ceeece16a0..6340cde6ccf3c 100644 --- a/airflow/models/mappedoperator.py +++ b/airflow/models/mappedoperator.py @@ -201,7 +201,7 @@ def _expand(self, **mapped_kwargs: "Mappable") -> "MappedOperator": from airflow.operators.empty import EmptyOperator validate_mapping_kwargs(self.operator_class, "expand", mapped_kwargs) - prevent_duplicates(self.kwargs, mapped_kwargs, fail_reason="mapping already partial") + prevent_duplicates(self.kwargs, mapped_kwargs, fail_reason="unmappable or already specified") ensure_xcomarg_return_value(mapped_kwargs) partial_kwargs = self.kwargs.copy()