-
I want to pass some data to subdags or taskgroups and from them to subsequent tasks. I have not found better way than create "input" and "output" tasks which explicitly use xcom push and pull (Do you know better solution?). |
Beta Was this translation helpful? Give feedback.
Answered by
Pocoder
Jun 17, 2022
Replies: 1 comment
-
For TaskGroups it can be done: from airflow.decorators import task_group
@task_group
def simple_task_group(val):
task_res = simple_task(val)
return task_res |
Beta Was this translation helpful? Give feedback.
0 replies
Answer selected by
Pocoder
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
For TaskGroups it can be done: