diff --git a/airflow_monitor/client.py b/airflow_monitor/client.py index b865a01..d19c7e8 100644 --- a/airflow_monitor/client.py +++ b/airflow_monitor/client.py @@ -204,14 +204,14 @@ class AirflowClient: resp = self._request( "GET", f"/dags/{encoded_dag_id}/dagRuns", - params=[("limit", 25), ("order_by", "-start_date")] + params=[("limit", 5), ("order_by", "-start_date")] + [("state", s) for s in states], ) else: resp = self._request( "GET", f"/dags/{encoded_dag_id}/dagRuns", - params={"order_by": "-start_date", "limit": 25}, + params={"order_by": "-start_date", "limit": 5}, ) runs = resp.json().get("dag_runs", []) else: diff --git a/airflow_monitor/config.py b/airflow_monitor/config.py index 3aabe32..7ea8781 100644 --- a/airflow_monitor/config.py +++ b/airflow_monitor/config.py @@ -16,7 +16,7 @@ class AirflowConfig: api_version: str = "auto" # "auto", "v1", or "experimental" timeout: int = 30 verify_ssl: bool = True - request_delay: float = 0.5 # delay between API calls (seconds) + request_delay: float = 0.1 # delay between API calls (seconds) @dataclasses.dataclass diff --git a/config.yaml b/config.yaml index 96b48fa..b04843e 100644 --- a/config.yaml +++ b/config.yaml @@ -27,7 +27,7 @@ airflow: verify_ssl: false # Delay between API requests to avoid overwhelming Airflow (seconds) - request_delay: 0.5 + request_delay: 0.1 monitor: # Interval between monitoring cycles (seconds)