jens-scheffler-bosch commented on issue #33078: URL: https://github.com/apache/airflow/issues/33078#issuecomment-1666761743
- The usage of `map_me(y=skipped).expand(x=run_me())` because the first part of `map_me(y=skipped)` creates a concrete task _instance_. This can not be expanded. - In contrast the `map_me.partial(y=skipped).expand(x=run_me())` creates a Python functools partial instantiated base on which expand will multiply. This is in your case the only way to make it not skipped, `y` will be initialited with an array of results of `skip_me`, potentially an empty array. - If you pass both `x` and `y` to the expansion function it will create a cross product of list of `x * y`. If `skip_me` has an empty list the cross product is zero length. -- 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]
