kaxil commented on code in PR #61063:
URL: https://github.com/apache/airflow/pull/61063#discussion_r2761620609
##########
task-sdk/src/airflow/sdk/api/client.py:
##########
@@ -682,6 +682,20 @@ def get(
return AssetEventsResponse.model_validate_json(resp.read())
+class DagOperations:
+ __slots__ = ("client",)
+
+ def __init__(self, client: Client):
+ self.client = client
+
+ def get_detail(self, dag_id: str):
+ """Get details of a DAG from the API server."""
+ resp = self.client.get(f"dags/{dag_id}")
+ # Return a simple dict-like response that can be accessed via
attributes
+ data = msgspec.json.decode(resp.read())
+ return type("DagResponse", (), data)
Review Comment:
We don't have such an endpoint on the execution API !
--
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]
