You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
Repository navigation
AIP-84 Migrate Dag Run related public endpoint to FastAPI #42701
changed the title [-][AIP-84] Migrate Dag Run related public endpoint to FastAPI [/-][+]AIP-84 Migrate Dag Run related public endpoint to FastAPI [/+]on Oct 3, 2024
Important to note. For triggering a dagrun, the api_connexion endpoint is missing a lot of the form fields that @jscheffl added to views.py. I think if its best if we consolidate to a single public trigger dag run endpoint in FastAPI.
Important to note. For triggering a dagrun, the api_connexion endpoint is missing a lot of the form fields that @jscheffl added to views.py. I think if its best if we consolidate to a single public trigger dag run endpoint in FastAPI.
I was always looking at /api/v1/ui/#/DAG/get_dag_details (airflow/api_connexion/endpoints/dag_endpoint.py:get_dag_details()` which contains a dict of all params definitions. I think this should contain all needed information to generate the form views.
Have not checked all default but looking at the fast API I feel like this is the same, have not checked for alle details of complete-ness. But this could be added-in there... I think --> http://localhost:29091/docs#/DAG/get_dag_details (Try it with example_params_ui_tutorial and take a look to params in the response.
And for the triggering after the form is rendered... I assume a "plain dict" just need to be passed as confto the trigger DAG run endpoint like today... so in my view the public API should be sufficient.
Activity
[-][AIP-84] Migrate Dag Run related public endpoint to FastAPI [/-][+]AIP-84 Migrate Dag Run related public endpoint to FastAPI [/+]bbovenzi commentedon Nov 6, 2024
Important to note. For triggering a dagrun, the api_connexion endpoint is missing a lot of the form fields that @jscheffl added to views.py. I think if its best if we consolidate to a single public trigger dag run endpoint in FastAPI.
jscheffl commentedon Nov 6, 2024
I was always looking at
/api/v1/ui/#/DAG/get_dag_details(airflow/api_connexion/endpoints/dag_endpoint.py:get_dag_details()` which contains a dict of all params definitions. I think this should contain all needed information to generate the form views.Have not checked all default but looking at the fast API I feel like this is the same, have not checked for alle details of complete-ness. But this could be added-in there... I think --> http://localhost:29091/docs#/DAG/get_dag_details (Try it with
example_params_ui_tutorialand take a look toparamsin the response.And for the triggering after the form is rendered... I assume a "plain dict" just need to be passed as
confto the trigger DAG run endpoint like today... so in my view the public API should be sufficient.FYI @shubhamraj-git
rawwar commentedon Nov 27, 2024
Thank you so much for your help @pierrejeambrun , @bugraoz93 , @omkar-foss . I learned a lot while contributing to this endpoint.
pierrejeambrun commentedon Nov 27, 2024
Thanks @rawwar for you contributions :)