AIP-84: Migrating GET Dataset events for DAG runs api to fastAPI

[amoghrajesh]

related #42370

Depends on #43783

Migrating the GET Dataset events for DAG runs to fastAPI

Responses:
Legacy

FastAPI

Swagger spec

---

^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named {pr_number}.significant.rst or {issue_number}.significant.rst, in newsfragments.

[amoghrajesh]

Only the last 3 commits are relevant here

[pierrejeambrun]

The base branch has been merged, branch needs rebasing.

Also you can add the legacy api tag to allow the CI to build.

[pierrejeambrun]

Nice just a couple of comments.

I'll do a final in depth review when the branch is rebased, it will make the review easier to only have the 'definitive' diff and not also the one from the base branch.

[pierrejeambrun]

Not sure I understand this comment, do you mind elaborate a little bit more please.

[amoghrajesh]

My PR and this one: #43881 had a common issue here. #43881 was handling this portion and meanwhile these values were changed. I will accomodate the changes from #43881 onto this one so that the response is like legacy

[amoghrajesh]

Made the change and it works as expected

[amoghrajesh]

Response:

{
    "asset_events": [
        {
            "id": 2,
            "asset_id": 1,
            "asset_uri": "wasb://somepath/",
            "extra": {},
            "source_task_id": "producer2",
            "source_dag_id": "producer2_dag",
            "source_run_id": "manual__2024-11-12T12:40:53.566380+00:00",
            "source_map_index": -1,
            "created_dagruns": [
                {
                    "run_id": "asset_triggered__2024-11-12T12:40:54.754807+00:00",
                    "dag_id": "multi_consumer_dag",
                    "logical_date": "2024-11-12T12:40:54.754807Z",
                    "start_date": "2024-11-12T12:40:54.903281Z",
                    "end_date": "2024-11-12T12:40:55.936560Z",
                    "state": "success",
                    "data_interval_start": "2024-11-12T12:40:51.405849Z",
                    "data_interval_end": "2024-11-12T12:40:53.566380Z"
                },
                {
                    "run_id": "asset_triggered__2024-11-12T12:40:54.754809+00:00",
                    "dag_id": "consumer2_dag",
                    "logical_date": "2024-11-12T12:40:54.754809Z",
                    "start_date": "2024-11-12T12:40:54.903329Z",
                    "end_date": "2024-11-12T12:40:55.939573Z",
                    "state": "success",
                    "data_interval_start": "2024-11-12T12:40:53.566380Z",
                    "data_interval_end": "2024-11-12T12:40:53.566380Z"
                }
            ],
            "timestamp": "2024-11-12T12:40:54.753857Z"
        }
    ],
    "total_entries": 1
}