You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2023/08/23 12:06:26 UTC
[airflow] branch main updated: Fix 2.7.0 db migration job errors (#33652)
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 4bdf908041 Fix 2.7.0 db migration job errors (#33652)
4bdf908041 is described below
commit 4bdf908041159c1d6ed019469190e08297928393
Author: Lipu Fei <li...@gmail.com>
AuthorDate: Wed Aug 23 14:06:20 2023 +0200
Fix 2.7.0 db migration job errors (#33652)
* Fix circular import from kubernetes_executor
* Do not validate SQL when initialising Sentry
---------
Co-authored-by: Lipu Fei <li...@kpn.com>
---
airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py | 2 +-
airflow/sentry.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
index 8e95f7a6c9..5bc39625da 100644
--- a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
+++ b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
@@ -37,7 +37,7 @@ from typing import TYPE_CHECKING, Any, Sequence
from sqlalchemy import select, update
from sqlalchemy.orm import Session
-from airflow import AirflowException
+from airflow.exceptions import AirflowException
try:
from airflow.cli.cli_config import (
diff --git a/airflow/sentry.py b/airflow/sentry.py
index 34133228ca..da46f92478 100644
--- a/airflow/sentry.py
+++ b/airflow/sentry.py
@@ -87,7 +87,7 @@ if conf.getboolean("sentry", "sentry_on", fallback=False):
# LoggingIntegration is set by default.
integrations = [sentry_flask]
- executor_class, _ = ExecutorLoader.import_default_executor_cls()
+ executor_class, _ = ExecutorLoader.import_default_executor_cls(validate=False)
if executor_class.supports_sentry:
from sentry_sdk.integrations.celery import CeleryIntegration