From 94ae3f75908b328d8dc69defcf499564fe1212bb Mon Sep 17 00:00:00 2001 From: Pankaj Date: Tue, 23 Jul 2024 11:50:03 +0530 Subject: [PATCH] Fix --- tests/test_example_dags.py | 19 ++++++++----------- 1 file changed, 8 insertions(+), 11 deletions(-) diff --git a/tests/test_example_dags.py b/tests/test_example_dags.py index e791ab878..50246aeeb 100644 --- a/tests/test_example_dags.py +++ b/tests/test_example_dags.py @@ -7,7 +7,6 @@ except ImportError: from functools import lru_cache as cache - import airflow import pytest from airflow.models.dagbag import DagBag @@ -31,7 +30,6 @@ IGNORED_DAG_FILES = ["performance_dag.py"] - # Sort descending based on Versions and convert string to an actual version MIN_VER_DAG_FILE_VER: dict[Version, list[str]] = { Version(version): MIN_VER_DAG_FILE[version] for version in sorted(MIN_VER_DAG_FILE, key=Version, reverse=True) @@ -88,15 +86,14 @@ def get_dag_ids() -> list[str]: AIRFLOW_VERSION in PARTIALLY_SUPPORTED_AIRFLOW_VERSIONS, reason="Airflow 2.9.0 and 2.9.1 have a breaking change in Dataset URIs, and Cosmos errors if `emit_datasets` is not False", ) -@pytest.mark.integration -@pytest.mark.parametrize("dag_id", get_dag_ids()) -def test_example_dag(session, dag_id: str): - if dag_id == "jaffle_shop_kubernetes": - return - dag_bag = get_dag_bag() - dag = dag_bag.get_dag(dag_id) - test_utils.run_dag(dag) - +# @pytest.mark.integration +# @pytest.mark.parametrize("dag_id", get_dag_ids()) +# def test_example_dag(session, dag_id: str): +# if dag_id == "jaffle_shop_kubernetes": +# return +# dag_bag = get_dag_bag() +# dag = dag_bag.get_dag(dag_id) +# test_utils.run_dag(dag) @pytest.mark.integration def test_example_dag_k8s(session):