We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6b03bd4 commit 0960c84Copy full SHA for 0960c84
python-sdk/src/astro/sql/operators/raw_sql.py
@@ -9,15 +9,10 @@
9
except ImportError: # pragma: no cover
10
from airflow.decorators import _TaskDecorator as TaskDecorator # type: ignore[attr-defined]
11
12
-import airflow
13
import pandas as pd
14
from airflow.decorators.base import task_decorator_factory
15
from sqlalchemy.engine import ResultProxy
16
-
17
-if airflow.__version__ >= "2.3":
18
- from sqlalchemy.engine.row import LegacyRow as SQLAlcRow
19
-else:
20
- from sqlalchemy.engine.result import RowProxy as SQLAlcRow
+from sqlalchemy.engine.row import LegacyRow as SQLAlcRow
21
22
from astro import settings
23
from astro.constants import RunRawSQLResultFormat
0 commit comments