This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 37c0038a18 change .first() to .scalar() (#27323)
37c0038a18 is described below
commit 37c0038a18ace092079d23988f76d90493ff294c
Author: Ayush Sharma <[email protected]>
AuthorDate: Mon Oct 31 08:01:58 2022 +0530
change .first() to .scalar() (#27323)
Co-authored-by: eladkal <[email protected]>
---
airflow/models/serialized_dag.py | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git a/airflow/models/serialized_dag.py b/airflow/models/serialized_dag.py
index 7ac98e7b8c..9c3c96871c 100644
--- a/airflow/models/serialized_dag.py
+++ b/airflow/models/serialized_dag.py
@@ -149,12 +149,8 @@ class SerializedDagModel(Base):
(timezone.utcnow() -
timedelta(seconds=min_update_interval)) < cls.last_updated,
)
)
- .first()
- is not None
+ .scalar()
):
- # TODO: .first() is not None can be changed to .scalar() once
we update to sqlalchemy 1.4+
- # as the associated sqlalchemy bug for MySQL was fixed
- # related issue :
https://github.com/sqlalchemy/sqlalchemy/issues/5481
return False
log.debug("Checking if DAG (%s) changed", dag.dag_id)
