renzo-sanchez-h commented on issue #39222:
URL: https://github.com/apache/airflow/issues/39222#issuecomment-2100960245
>
>
> > Hello there, I've just encountered the same issue.
> > It doesn't only happen with classic operators, but anything in a task
group scope, such as:
> > ```
> > @task_group
> > def process_model_requests(model_name):
> > config_results =
prepare_pod_config(task_id=f"config_for_{model_name}")
> > result_paths = prepare_pods(config_results, f"for_{model_name}")
> > config_results >> result_paths
> > ```
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> > I have the version 2.6.3 though.
>
> Interesting, not anything in a task group though, as python operator
created with taskflow api seems to work well. Haven't tried with classic python
operator.
Yes, sorry. I meant while using dynamic task mapping. Like the original post.
```
prefix = "process"
task_params = [{"task_id": "_".join([prefix, str(i + 1)]), "model_name":
f"model_{i}"} for i in range(3)]
process_model_requests.expand_kwargs(task_params)
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
