This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 1394b1a986 Make expand() error vague so it's not misleading (#24018)
1394b1a986 is described below
commit 1394b1a986bf63f6910eaaf7b5d92f24f2623ff4
Author: Tzu-ping Chung <[email protected]>
AuthorDate: Wed Jun 1 20:24:35 2022 -0400
Make expand() error vague so it's not misleading (#24018)
---
airflow/models/mappedoperator.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/models/mappedoperator.py b/airflow/models/mappedoperator.py
index 663ceeece1..6340cde6cc 100644
--- a/airflow/models/mappedoperator.py
+++ b/airflow/models/mappedoperator.py
@@ -201,7 +201,7 @@ class OperatorPartial:
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()