RNHTTR edited a comment on issue #14163:
URL: https://github.com/apache/airflow/issues/14163#issuecomment-794733933
I think `BulkStateFetcher`'s `get_many` method expects an iterable of
`AsyncResult`s. So, I think the map is necessary.
```python
states_by_celery_task_id = self.bulk_state_fetcher.get_many(
map(operator.itemgetter(0), celery_tasks.values())
)
```
This bit creates a map object that gets the 0th element of each tuple (i.e.
AsyncResult) in `celery_tasks.values()` I _think_ all we need to do is cast the
map object to a list:
```python
list(map(operator.itemgetter(0), celery_tasks.values()))
```
I'm gonna dig a bit deeper to confirm & hopefully submit a PR tomorrow.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
