This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch v2-7-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 8a83d403fc7bff9be10343d1364624c7aec3b117
Author: Pankaj Koti <pankajkoti...@gmail.com>
AuthorDate: Sun Oct 8 06:05:29 2023 -0700
Add missing multiple_outputs=True param in the TaskFlow example (#34812)
When storing XCOM as dict and using it in subsequent it needs to be
unrolled so that keys of the dict are stored and can be used as in below task
(cherry picked from commit fc4093922023896cd5e12e90b9fe2c803ba3e670)
---
docs/apache-airflow/core-concepts/taskflow.rst | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/apache-airflow/core-concepts/taskflow.rst
b/docs/apache-airflow/core-concepts/taskflow.rst
index 8dcd52acd1..0794fa8533 100644
--- a/docs/apache-airflow/core-concepts/taskflow.rst
+++ b/docs/apache-airflow/core-concepts/taskflow.rst
@@ -31,7 +31,7 @@ TaskFlow takes care of moving inputs and outputs between your
Tasks using XComs
def get_ip():
return my_ip_service.get_main_ip()
- @task
+ @task(multiple_outputs=True)
def compose_email(external_ip):
return {
'subject':f'Server connected from {external_ip}',
