jscheffl commented on code in PR #44433:
URL: https://github.com/apache/airflow/pull/44433#discussion_r1864376303
##########
providers/src/airflow/providers/edge/worker_api/routes/_v2_routes.py:
##########
@@ -90,6 +98,44 @@ def set_state_v2(worker_name: str, body: dict[str, Any],
session=NEW_SESSION) ->
return e.to_response() # type: ignore[attr-defined]
+@provide_session
+def job_fetch_v2(worker_name: str, body: dict[str, Any] | None = None,
session=NEW_SESSION) -> Any:
Review Comment:
That would be the type in FastAPI. But here we are in the "compatability
leyer" which uses the fucntions of FastAPI and wraps into the same endpoint for
Connexion. Connexion gets the JSON model as dump, not a pydantic object.
--
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]
