This is an automated email from the ASF dual-hosted git repository. pankajkoti pushed a commit to branch pankajkoti-patch-1 in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 9ebd2db6279bb62e65daf429d02f02abf370be99 Author: Pankaj Koti <pankajkoti...@gmail.com> AuthorDate: Fri Oct 6 16:41:58 2023 -0700 Update taskflow.rst 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 --- 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 abe9da25cb..c1de77d68c 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}',