tanelk commented on issue #37073:
URL: https://github.com/apache/airflow/issues/37073#issuecomment-1916117531
I looked at it a bit more and the issue seems to be with the
airflow.models.taskmap.TaskMap design. The
airflow.models.taskinstance._record_task_map_for_downstreams method does not
look at the multiple_outputs value and will create a single TaskMap from the
dictionary. It probably should create multiple task maps, but that is a quite
significant change.
I found a simple workaround for the bug - a minimalistic python function,
that just returns the input value:
```
@task
def pass_through(values):
return values
```
And then use it like this:
```
process.override(group_id='process1').expand(value=pass_through(values['values1']))
process.override(group_id='process2').expand(value=pass_through(values['values2']))
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
