Make expand() error vague so it's not misleading (#24018)

apache · Jun 2, 2022 · 1394b1a · 1394b1a
1 parent 9398586
commit 1394b1a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()