[GitHub] [airflow] uranusjr commented on pull request #27491: Expand tasks in mapped group at run time

[GitBox <gi...@apache.org>]

uranusjr commented on PR #27491:
URL: https://github.com/apache/airflow/pull/27491#issuecomment-1305409323

   Alright, everything should work now. Again, the first two commits are not relevant, only the latter two. The logic change is mostly
   
   1. Move things from MappedOperator to AbstractOperator.
   2. Remove some checks so task expansion works not only for MappedOperator, but also BaseOperator in a MappedTaskGroup.
   3. Add logic so MappedArgument (stand-in reference passed from MappedTaskGroup to BaseOperator in it) can register task dependencies like XComArg.
   
   Some minor refactoring is involved as well. Since most of the logic is exactly the same as MappedOperator, I only added one test to ensure the same code paths are visited for MappedTaskGroup child operators.


-- 
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-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org