Skip to content

Commit d1a1867

Browse files
committed
Update example dag import and fix mypy error
1 parent 5aae076 commit d1a1867

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

providers/common/compat/src/airflow/providers/common/compat/version_compat.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@ def get_base_airflow_version_tuple() -> tuple[int, int, int]:
3232
return airflow_version.major, airflow_version.minor, airflow_version.micro
3333

3434

35-
AIRFLOW_V_3_0_PLUS = get_base_airflow_version_tuple() >= (3, 0, 0)
36-
AIRFLOW_V_3_1_PLUS = get_base_airflow_version_tuple() >= (3, 1, 0)
35+
AIRFLOW_V_3_0_PLUS: bool = get_base_airflow_version_tuple() >= (3, 0, 0)
36+
AIRFLOW_V_3_1_PLUS: bool = get_base_airflow_version_tuple() >= (3, 1, 0)
3737

3838
if AIRFLOW_V_3_0_PLUS:
3939
from airflow.sdk import BaseOperator

providers/standard/src/airflow/providers/standard/example_dags/example_bash_decorator.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -23,11 +23,7 @@
2323
from airflow.providers.standard.operators.empty import EmptyOperator
2424
from airflow.providers.standard.utils.weekday import WeekDay
2525
from airflow.sdk import chain, dag, task
26-
27-
try:
28-
from airflow.sdk.exceptions import AirflowSkipException
29-
except ImportError:
30-
from airflow.exceptions import AirflowSkipException # type: ignore[no-redef,attr-defined]
26+
from airflow.sdk.exceptions import AirflowSkipException
3127

3228

3329
@dag(schedule=None, start_date=pendulum.datetime(2023, 1, 1, tz="UTC"), catchup=False)

0 commit comments

Comments
 (0)