get_event_log
Retrieve specific event log entries from Apache Airflow clusters to monitor workflow execution and troubleshoot issues.
Instructions
[Tool Role]: Retrieves a specific event log entry.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| event_log_id | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- The handler function for the 'get_event_log' tool. It makes a GET request to the Airflow API endpoint /eventLogs/{event_log_id} to retrieve the specific event log entry and returns the JSON response.
async def get_event_log(event_log_id: int) -> Dict[str, Any]: """[Tool Role]: Retrieves a specific event log entry.""" resp = await airflow_request("GET", f"/eventLogs/{event_log_id}") resp.raise_for_status() return resp.json()