AIP-84 Migrate public endpoints from api_connexion to the new rest api

[pierrejeambrun]

Body

#42366 is taking care of migrating private endpoints.

This issue focus on migrating all the public ones. Ideally they shouldn't change too much and be feature rich compare to airflow 2.x.

An exemple PR can be found here #42196

Tasks (total ~ 81 endpoints)

Backfill (6 endpoints)

Config (2 endpoints) @rawwar

• AIP-84 Migrate Config related public endpoint to FastAPI  #42745 @rawwar

Connection @bugraoz93 (6 endpoints)

• api_connexion/endpoints/connection_endpoint.py delete_connection AIP-84 Migrate the public endpoint Delete Connection to FastAPI #42559 @bugraoz93
• api_connexion/endpoints/connection_endpoint.py get_connection AIP-84 Migrate the public endpoint Get Connection to FastAPI #42590 @rawwar
• api_connexion/endpoints/connection_endpoint.py get_connections AIP-84 Migrate the public endpoint Get Connections to FastAPI  #42591 @bugraoz93
• api_connexion/endpoints/connection_endpoint.py patch_connection AIP-84 Migrate the public endpoint Patch Connection to FastAPI #42592 @bugraoz93
• api_connexion/endpoints/connection_endpoint.py post_connection AIP-84 Migrate the public endpoint Post Connection to FastAPI  #42593 @bugraoz93
• api_connexion/endpoints/connection_endpoint.py test_connection AIP-84 Migrate the public endpoint Test Connection to FastAPI #42594 @bugraoz93

DAG (5 endpoints)

• api_connexion/endpoints/dag_endpoint.py get_dag_details AIP-84 Migrate the public endpoint DAG Details to FastAPI #42453 @omkar-foss
• api_connexion/endpoints/dag_endpoint.py patch_dag AIP-84 Migrate the public endpoint Update DAG to FastAPI #42468 @pierrejeambrun
• api_connexion/endpoints/dag_endpoint.py patch_dags AIP-84 Migrate the public endpoint Batch Update DAG to FastAPI #42544 @pierrejeambrun
• api_connexion/endpoints/dag_endpoint.py get_dag AIP-84 Migrate the public endpoint Get DAG to FastAPI #42652 @omkar-foss
• api_connexion/endpoints/dag_endpoint.py delete_dag AIP-84 Migrate the public endpoint Delete DAG to FastAPI #42650 @omkar-foss

Dag Parsing (1 endpoint)

Dag Runs @rawwar (9 endpoints)

• All dag run endpointsapi_connexion/endpoints/dag_run_endpoint.py AIP-84 Migrate Dag Run related public endpoint to FastAPI  #42701 @rawwar

Dag Source (1 endpoint)

• AIP-84 Migrate the public endpoint Get DAG Source to FastAPI #42876 @omkar-foss

Dag Stats (1 endpoint)

• AIP-84 Migrate the public endpoint Get DAG Stats to FastAPI #42877 @omkar-foss

Dag Warnings (1 endpoint) @rawwar

• AIP-84 Migrate DagWarning public endpoint to FastAPI #42748 @rawwar

Dataset / Assets (10 endpoints)

Event Logs (2 endpoints)

Extra Link (1 endpoint)

Monitor (2 endpoints)

• AIP-84 Migrate public get Health info to FastAPI #42937 @bbovenzi
• AIP-84 Migrate the public endpoint Get Airflow Version Info to FastAPI #42879 @omkar-foss

Import Error (2 endpoints)

Log (1 endpoint)

Plugin (1 endpoint)

• AIP-84 Get Plugins #43125 @pierrejeambrun

Pool (5 endpoints) @pierrejeambrun

Provider (1 endpoint)

• AIP-84 Get Providers #43159 @pierrejeambrun

Task (2 endpoints) @omkar-foss

• AIP-84 Migrate the public endpoint Get Task to FastAPI #42874 @omkar-foss
• AIP-84 Migrate the public endpoint Get Tasks to FastAPI #42875 @omkar-foss

Task Instance (15 endpoints)

Variables (5 endpoints)

• AIP-84 Delete Variable #42798 @pierrejeambrun
• AIP-84 Get Variable #42834 @pierrejeambrun
• AIP-84 Patch Variable #42929 @pierrejeambrun
• AIP-84 Post variable #42948 @pierrejeambrun
• AIP-84 Get Variables #43083 @pierrejeambrun

XCom (2 endpoints)

• AIP-84 Migrate XCom get entry public endpoint to FastAPI #42978 @michaeljs-c
• AIP-84 Migrate XCom get entries public endpoint to FastAPI #42980 @michaeljs-c

Committer

• I acknowledge that I am a maintainer/committer of the Apache Airflow project.

[omkar-foss]

Trimming down views.py is very tempting 😄

May I pick this up? If yes, please assign this issue to me. Thanks!

[pierrejeambrun]

Hello @omkar-foss,

views.py are mostly 'rendered' front end that will get replaced by the new UI react, in views.py you also find private/UI REST route, most of them are with the /object/ prefix, such as def grid_data. If you want to work on those UI dedicated endpoints you can that would be part of #42366.

This issue focuses on the public endpoints, those are located under the api_connexion folder.

In anycase, just mention the endpoint you are working on, so people do not do the same ones, and I will update the description to track that :). I think we should do one at the time.

[omkar-foss]

Hi @pierrejeambrun, thank you for explaining it to me, much appreciate it.

I'll start migrating the public endpoints, beginning with migration of the DAG Details API (get_dag_details) in api_connexion/endpoints/dag_endpoint.py.

Since this is a meta issue (missed that previously!), I'll create the issue/PR corresponding to the endpoint(s) that I'll be working on and link to this issue (like usual).

P.S: views.py will have to wait :)

[bugraoz93]

Thanks for creating the ticket @pierrejeambrun! Let me take connection endpoints

[pierrejeambrun]

Great, thanks @bugraoz93

[bugraoz93]

Thanks for assigning! Let me save you from regular updates :) I created issues for all the endpoints in connections.

[pierrejeambrun]

Great, thanks @bugraoz93. I just updated the meta issue with those new additions. Let me know if you plan to work on all of them so I can assign you, or just some of them so I can label the others with good first issue and let other contributors grab them :)

[bugraoz93]

I am planning to work on all of them @pierrejeambrun. if you can assign them to me, that would be great! Thanks :)

[omkar-foss]

Hey folks! After #42631 (open for review), I can pick up these two next in order:

1. get_dag - AIP-84 Migrate the public endpoint Get DAG to FastAPI #42652
2. delete_dag - AIP-84 Migrate the public endpoint Delete DAG to FastAPI #42650

With these 2 done, I suppose we should have the dags.py migration complete. When you find some time, please update this meta and assign these to me, thank you! 😃

[bbovenzi]

@omkar-foss Assigned. Thanks for picking these issues up!

[rawwar]

I am working on the following

1. get_connection - AIP-84 Migrate GET connection to FastAPI API #42674
2. get_connections - AIP-84 Migrate the public endpoint Get Connections to FastAPI  #42677

[potiuk]

That would be great, the minimum Pydantic version that is fixed is v2.6.4, this commit for quick reference.

Added min version for Pydantic in #42694

[pierrejeambrun]

@rawwar

I am working on the following

get_connection - #42674
get_connections - AIP-84 Migrate the public endpoint Get Connections to FastAPI #42677`

Thanks for your contribution and help on AIP-84, as mentioned above, I think @bugraoz93 is already working on connections endpoints, or is planning to do so. Feel free to choose any other endpoints that looks cool to you, under api_connexions/endpoints. Besides dag_endpoint and connection_endpoint eveything is up for a grab, just let me know and I will assign you :)

[pierrejeambrun]

Assigning myself to variables

[omkar-foss]

I've created new issues for sections Dag Source (1 endpoint), Dag Stats (1 endpoint), Task (2 endpoints) and Version (1 endpoint). List as below:

1. AIP-84 Migrate the public endpoint Get DAG Source to FastAPI #42876
2. AIP-84 Migrate the public endpoint Get DAG Stats to FastAPI #42877
3. AIP-84 Migrate the public endpoint Get Task to FastAPI #42874
4. AIP-84 Migrate the public endpoint Get Tasks to FastAPI #42875
5. AIP-84 Migrate the public endpoint Get Airflow Version Info to FastAPI #42879

Please assign these to me, I'll pick these up one by one in the next few days, right after #42650. Cheers.

[pierrejeambrun]

@omkar-foss assigned and meta issue updated, thanks :)

[michaeljs-c]

Hi @pierrejeambrun I've added issues for XCom, please assign to me 🙂 thanks

[pierrejeambrun]

Hi @pierrejeambrun I've added issues for XCom, please assign to me 🙂 thanks

Done, and meta task is updated.

Thanks for taking those ones @michaeljs-c!