code: def test_get_dag_runs_success_with_state_parameter(self):
      url_template = "/api/experimental/dags/{}/dag_runs?state=queued"
      dag_id = "example_bash_operator"
      # Create DagRun
      dag_run = trigger_dag(
          dag_id=dag_id, run_id="test_get_dag_runs_success"
      )
  
      response = self.app.get(url_template.format(dag_id))
      assert 200 == response.status_code
      data = json.loads(response.data.decode("utf-8"))
  
      assert isinstance(data, list)
      assert len(data) == 1
      assert data[0]["dag_id"] == dag_id
      assert data[0]["id"] == dag_run.id
  
file_path: airflow/tests/www/api/experimental/test_dag_runs_endpoint.py
imports: from __future__ import annotations
  import json
  import pytest
  from airflow.api.common.trigger_dag import trigger_dag
  from airflow.models import DagBag, DagRun
  from airflow.models.serialized_dag import SerializedDagModel
  from airflow.settings import Session
label_desc: Use image node_id 4 for calling the TestDagRunsEndpoint obj's underlying member method code with example usage: obj.test_get_dag_runs_success_with_state_parameter() without return types