Move grid_data endpoint to REST API

[bbovenzi]

Description

Migrate the object/grid_data endpoint here to the REST API.

With #23415, we can simplify this endpoint too and only return the groups object.

Use case/motivation

No response

Related issues

No response

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[tirkarthi]

@bbovenzi I can take this. Please add a permalink to the github code that you want to migrate to rest API . I couldn't find objects/tree_data endpoint in current views.

[bbovenzi]

oh yes, we renamed it to grid_data. I updated the link too.

We probably don't need to return the dag_runs part of the response and instead use the list dag runs endpoint. Message me before you start work on this, I may want to change a few other things.

[bbovenzi]

Semi-related: #23772

Either before or after this issue we should try to optimize the function to generate this grid data.

[tirkarthi]

@bbovenzi I can start working on it now. I see that you have made some optimizations as part of #23813 too. It will be helpful to have a sample response so that I can give a first draft attempt since you already mentioned dag_runs are not needed.

[bbovenzi]

This should be an internal API endpoint, not a public one. Being in the webserver and views.py is fine for now.

[karakanb]

I would appreciate if this was available through the REST API as well, it is a very concise way of knowing about the historical context around task instances, and it avoids sending many separate requests to get the same information.

@bbovenzi would you oppose this being part of the public API?

[bbovenzi]

@karakanb what is your use-case? I would still want to keep it separate so that we can quickly iterate on the grid view. But maybe the existing task instances REST API endpoints can be improved.

[karakanb]

My usecase is to integrate our Airflow pipelines with some of internal tooling, and grid view has been the perfect way to do so.

Currently, since there is no grid endpoint, what I have to do is:

• fetch all task instances between after a specific date
• Fetch tasks, because not all tasks have had a run
• Fetch dagruns, because not all dagruns are returned as part of the task instances

This means many requests, and especially when there are many task instances it takes many seconds to fetch the data because of additional pagination in the requests, whereas the grid endpoint can do this very quickly. Increasing the page sizes don't help much either for some reason, which means we are stuck with very slow loading times compared to the grid view data.

I might also be doing something wrong, therefore if you have recommendations please let me know.

[potiuk]

I think "Generic" bulk retrieval of Airflow tasks (not optimized for UI but for bulk retrieval of data) could be added. Maybe you would like to design and contribute such an endpoint @karakanb - you seem to know hat you are doing with Python, adding yet another API endpoint should be easy following the exisitng ones and if you get it "generic" enough, it would be useful for others too.