This is an automated email from the ASF dual-hosted git repository.
jedcunningham 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 d2e6ab01e9e Bump cadwyn min version to 5.1.3 (#48091)
d2e6ab01e9e is described below
commit d2e6ab01e9e9493a7e7cca126e91fec699fe45a7
Author: Jed Cunningham <[email protected]>
AuthorDate: Fri Mar 21 22:47:26 2025 -0600
Bump cadwyn min version to 5.1.3 (#48091)
This fixes static checks on main, and ensures when we generate
consistent datamodels.
---
airflow-core/pyproject.toml | 2 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 20 ++++++++++++++++++++
2 files changed, 21 insertions(+), 1 deletion(-)
diff --git a/airflow-core/pyproject.toml b/airflow-core/pyproject.toml
index 471e62f50be..0329bab0e56 100644
--- a/airflow-core/pyproject.toml
+++ b/airflow-core/pyproject.toml
@@ -72,7 +72,7 @@ dependencies = [
# Blinker use for signals in Flask, this is an optional dependency in
Flask 2.2 and lower.
# In Flask 2.3 it becomes a mandatory dependency, and flask signals are
always available.
"blinker>=1.6.2",
- "cadwyn>=5.1.2",
+ "cadwyn>=5.1.3",
"colorlog>=6.8.2",
"configupdater>=3.1.1",
"cron-descriptor>=1.2.24",
diff --git a/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
b/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
index 0ed6fc985be..2fb929516cf 100644
--- a/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
+++ b/task-sdk/src/airflow/sdk/api/datamodels/_generated.py
@@ -97,6 +97,14 @@ class DagRunAssetReference(BaseModel):
class DagRunState(str, Enum):
+ """
+ All possible states that a DagRun can be in.
+
+ These are "shared" with TaskInstanceState in some parts of the code,
+ so please ensure that their values always match the ones with the
+ same name in TaskInstanceState.
+ """
+
QUEUED = "queued"
RUNNING = "running"
SUCCESS = "success"
@@ -112,6 +120,10 @@ class DagRunStateResponse(BaseModel):
class DagRunType(str, Enum):
+ """
+ Class with DagRun types.
+ """
+
BACKFILL = "backfill"
SCHEDULED = "scheduled"
MANUAL = "manual"
@@ -119,6 +131,10 @@ class DagRunType(str, Enum):
class IntermediateTIState(str, Enum):
+ """
+ States that a Task Instance can be in that indicate it is not yet in a
terminal or running state.
+ """
+
SCHEDULED = "scheduled"
QUEUED = "queued"
RESTARTING = "restarting"
@@ -256,6 +272,10 @@ class TITargetStatePayload(BaseModel):
class TerminalStateNonSuccess(str, Enum):
+ """
+ TaskInstance states that can be reported without extra information.
+ """
+
FAILED = "failed"
SKIPPED = "skipped"
REMOVED = "removed"
