ashb commented on pull request #22341: URL: https://github.com/apache/airflow/pull/22341#issuecomment-1077490856
I think that if we find no mapped TIs we should load the dag and check, because there it might be worth being able to differentiate between: - mapped item was zero length, whole thing was skipped - mapped item returned one item, and that one task execution chose to skip. We could either load the DAG and check if `task.is_mapped`? Or just load all TIs (no map_index SQL filtering) and check things further only if we find an index of -1 (so that the "default" case of called on an expanded mapped index can run without extra queries, as loading the DAG is not free.) -- 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]
