We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0e4508c commit bca7ac3Copy full SHA for bca7ac3
airflow-core/src/airflow/cli/commands/task_command.py
@@ -215,9 +215,7 @@ def _get_ti(
215
except NotFullyPopulated:
216
pass # Dynamic mapping — cannot validate at parse time
217
except NotMapped:
218
- raise ValueError(
219
- f"Task '{task.task_id}' is not mapped; map_index must be -1."
220
- )
+ raise ValueError(f"Task '{task.task_id}' is not mapped; map_index must be -1.")
221
dag_version = DagVersion.get_latest_version(dag.dag_id, session=session)
222
if not dag_version:
223
# TODO: Remove this once DagVersion.get_latest_version is guaranteed to return a DagVersion/raise
0 commit comments