uranusjr commented on code in PR #27723:
URL: https://github.com/apache/airflow/pull/27723#discussion_r1024802028
##########
airflow/models/expandinput.py:
##########
@@ -57,9 +57,9 @@ class MappedArgument(ResolveMixin):
_key: str
def get_task_map_length(self, run_id: str, *, session: Session) -> int |
None:
- # TODO (AIP-42): Implement run-time task map length inspection.
- # This simply marks the value as un-expandable at parse-time.
- return None
+ # TODO (AIP-42): Implement run-time task map length inspection. This is
+ # needed when we implement task mapping inside a mapped task group.
+ raise NotImplementedError()
Review Comment:
_Task mapping inside a mapped task group_ as in
```python
@task_group
def tg(a):
@task
def f(x):
print(x)
# This is currently not allowed to simplify UI and API.
f.expand(x=a)
tg.expand(a=[[1, 2], [3, 4]])
```
--
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]
