Skip to content

Commit e2df3c1

Browse files
committed
move TaskNotFound to sdk
1 parent 6ef3c93 commit e2df3c1

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

airflow-core/src/airflow/dag_processing/processor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636
)
3737
from airflow.configuration import conf
3838
from airflow.dag_processing.dagbag import DagBag
39-
from airflow.exceptions import TaskNotFound
39+
from airflow.sdk.exceptions import TaskNotFound
4040
from airflow.sdk.execution_time.comms import (
4141
ConnectionResult,
4242
DeleteVariable,

airflow-core/src/airflow/exceptions.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -311,7 +311,6 @@ def __init__(self, dag_id: str | None = None, message: str | None = None):
311311
"AirflowSkipException": "airflow.sdk.exceptions.AirflowSkipException",
312312
"AirflowTaskTimeout": "airflow.sdk.exceptions.AirflowTaskTimeout",
313313
"AirflowFailException": "airflow.sdk.exceptions.AirflowFailException",
314-
# TODO: This will be handled as part of https://github.com/apache/airflow/pull/55111
315314
"ParamValidationError": "airflow.sdk.exceptions.ParamValidationError",
316315
"TaskDeferred": "airflow.sdk.exceptions.TaskDeferred",
317316
}

0 commit comments

Comments
 (0)