def dag_runs(dag_id):
    """
    Returns a list of Dag Runs for a specific DAG ID.
    :query param state: a query string parameter '?state=queued|running|success...'
    :param dag_id: String identifier of a DAG
    :return: List of DAG runs of a DAG with requested state,
    or all runs if the state is not specified
    """
    try:
        state = request.args.get('state')
        dagruns = get_dag_runs(dag_id, state)
    except AirflowException as err:
        _log.info(err)
        response = jsonify(error="{}".format(err))
        response.status_code = 400
        return response

    return jsonify(dagruns)
def dag_runs(dag_id):
    
    try:
        state = request.args.get('state')
        dagruns = get_dag_runs(dag_id, state)
    except AirflowException as err:
        _log.info(err)
        response = jsonify(error="{}".format(err))
        response.status_code = 400
        return response

    return jsonify(dagruns)
def dag_runs ( dag_id ) : try : state = request . args . get ( 'state' ) dagruns = get_dag_runs ( dag_id , state ) except AirflowException as err : _log . info ( err ) response = jsonify ( error = "{}" . format ( err ) ) response . status_code = 400 return response return jsonify ( dagruns )
Returns a list of Dag Runs for a specific DAG ID.
    :query param state: a query string parameter '?state=queued|running|success...'
    :param dag_id: String identifier of a DAG
    :return: List of DAG runs of a DAG with requested state,
    or all runs if the state is not specified
Returns a list of Dag Runs for a specific DAG ID . : query param state : a query string parameter ?state = queued|running|success ... : param dag_id : String identifier of a DAG : return : List of DAG runs of a DAG with requested state or all runs if the state is not specified