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 b0ed5df275 update `task-generated mapping` example (#23424)
b0ed5df275 is described below
commit b0ed5df2759e859aea2dee68ee0c35840901276d
Author: aspain <[email protected]>
AuthorDate: Fri Jun 24 00:28:54 2022 -0400
update `task-generated mapping` example (#23424)
Co-authored-by: James Timmins <[email protected]>
Co-authored-by: Tzu-ping Chung <[email protected]>
---
docs/apache-airflow/concepts/dynamic-task-mapping.rst | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/apache-airflow/concepts/dynamic-task-mapping.rst
b/docs/apache-airflow/concepts/dynamic-task-mapping.rst
index 65017b49cd..76587a77f3 100644
--- a/docs/apache-airflow/concepts/dynamic-task-mapping.rst
+++ b/docs/apache-airflow/concepts/dynamic-task-mapping.rst
@@ -157,7 +157,7 @@ Up until now the examples we've shown could all be achieved
with a ``for`` loop
@task
def consumer(arg):
- print(list(arg))
+ print(arg)
with DAG(dag_id="dynamic-map", start_date=datetime(2022, 4, 2)) as dag:
