Run only one dag for integration test

astronomer · Aug 26, 2024 · 3337df6 · 3337df6
1 parent 237c374
commit 3337df6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/test_dag_example.py b/tests/test_dag_example.py
@@ -60,7 +60,7 @@ def test_dag_runs(setup_airflow_db, dag_id, dag, fileloc):
     print(f"Testing DAG: {dag_id}, located at: {fileloc}")
     assert dag is not None, f"DAG {dag_id} not found!"
 
-    if dag_id == "Ray_Taskflow_Example_Existing_Cluster":
+    if dag_id != "Ray_Taskflow_Example":
         return
 
     try: