diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index 939039b0827fb..f7ca3e9fb879c 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -425,6 +425,7 @@ repos: ^airflow-ctl.*\.py$| ^airflow-core/src/airflow/models/.*\.py$| ^airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py$| + ^airflow-core/tests/unit/utils/test_state.py$| ^airflow-core/tests/unit/utils/test_db_cleanup.py$| ^dev/airflow_perf/scheduler_dag_execution_timing.py$| ^providers/openlineage/.*\.py$| diff --git a/airflow-core/tests/unit/utils/test_state.py b/airflow-core/tests/unit/utils/test_state.py index 463f943320462..88a1925842e8b 100644 --- a/airflow-core/tests/unit/utils/test_state.py +++ b/airflow-core/tests/unit/utils/test_state.py @@ -19,6 +19,7 @@ from datetime import timedelta import pytest +from sqlalchemy import select from airflow.models.dagrun import DagRun from airflow.sdk import DAG @@ -58,22 +59,18 @@ def test_dagrun_state_enum_escape(testing_dag_bundle): triggered_by=DagRunTriggeredByType.TEST, ) - query = session.query( - DagRun.dag_id, - DagRun.state, - DagRun.run_type, - ).filter( + stmt = select(DagRun.dag_id, DagRun.state, DagRun.run_type).where( DagRun.dag_id == dag.dag_id, # make sure enum value can be used in filter queries DagRun.state == DagRunState.QUEUED, ) - assert str(query.statement.compile(compile_kwargs={"literal_binds": True})) == ( + assert str(stmt.compile(compile_kwargs={"literal_binds": True})) == ( "SELECT dag_run.dag_id, dag_run.state, dag_run.run_type \n" "FROM dag_run \n" "WHERE dag_run.dag_id = 'test_dagrun_state_enum_escape' AND dag_run.state = 'queued'" ) - rows = query.all() + rows = session.execute(stmt).all() assert len(rows) == 1 assert rows[0].dag_id == dag.dag_id # make sure value in db is stored as `queued`, not `DagRunType.QUEUED`