diff --git a/openmetadata-airflow-apis/src/openmetadata/api/rest_api.py b/openmetadata-airflow-apis/src/openmetadata/api/rest_api.py index 04877cd3b90..64d9f6c615f 100644 --- a/openmetadata-airflow-apis/src/openmetadata/api/rest_api.py +++ b/openmetadata-airflow-apis/src/openmetadata/api/rest_api.py @@ -219,6 +219,12 @@ class REST_API(AppBuilderBaseView): """ dag_id: str = self.get_request_arg(request, "dag_id") + if not dag_id: + return ApiResponse.error( + status=ApiResponse.STATUS_BAD_REQUEST, + error=f"Missing dag_id argument in the request", + ) + try: return status(dag_id)