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()

Reply via email to