Skip to content

airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
bugraoz93 merged 10 commits into from
May 26, 2026
Merged

airflow-ctl 0.1.5: test to stable #67294

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
ef422ff
[airflow-ctl-v0-1-test] Allow remote version check without authentica…
bugraoz93 Apr 26, 2026
c22b090
[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…
bugraoz93 Apr 26, 2026
8c6bb32
[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …
bugraoz93 Apr 27, 2026
cb1426c
Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)
potiuk Apr 28, 2026
2e10497
[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …
choo121600 May 1, 2026
a781f73
[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…
bugraoz93 May 23, 2026
e65c3ec
[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…
bugraoz93 May 24, 2026
192441e
[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…
bugraoz93 May 24, 2026
871710c
Sync main to backport branch for airflowctl (#67559)
bugraoz93 May 26, 2026
f3bac6c
[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…
bugraoz93 May 26, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions .github/workflows/test-providers.yml
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
run: >
breeze release-management prepare-task-sdk-distributions
--distribution-format ${{ matrix.package-format }}
- name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
run: >
breeze release-management prepare-airflow-ctl-distributions
--distribution-format ${{ matrix.package-format }}
- name: "Verify ${{ matrix.package-format }} packages with twine"
run: |
uv tool uninstall twine || true
Expand Down
9 changes: 6 additions & 3 deletions Dockerfile
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
fi

# Find Provider/TaskSDK/CTL distributions in docker-context files
readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
# Find Provider/TaskSDK/CTL distributions in docker-context files.
# NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
# ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
# glob must say ``ctl``, not ``airflowctl``.
readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
echo
echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
echo
Expand Down
2 changes: 1 addition & 1 deletion Dockerfile.ci
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down
29 changes: 18 additions & 11 deletions airflow-core/pyproject.toml
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
"gitdb==4.0.12",
"GitPython==3.1.46",
"GitPython==3.1.50",
"hatchling==1.29.0",
"packaging==26.1",
"pathspec==1.0.4",
"packaging==26.2",
"pathspec==1.1.1",
"pluggy==1.6.0",
"smmap==5.0.3",
"tomli==2.4.1; python_version < '3.11'",
"trove-classifiers==2026.1.14.14",
"trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
"a2wsgi>=1.10.8",
"cachetools>=6.0.0",
# aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
# See https://github.com/omnilib/aiosqlite/issues/369
# It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
"dill>=0.2.2",
"fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
"uvicorn>=0.37.0",
# Starlette 1.0.0 breaks the API server. Needs more investigation
# https://github.com/apache/airflow/issues/64116
"starlette>=0.45.0,<1",
"starlette>=0.45.0",
"httpx>=0.25.0",
'importlib_metadata>=6.5;python_version<"3.12"',
'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
"tenacity>=8.3.0",
"termcolor>=3.0.0",
"typing-extensions>=4.14.1",
# https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
"universal-pathlib>=0.3.8",
"uuid6>=2024.7.10",
"apache-airflow-task-sdk==1.2.1",
"apache-airflow-task-sdk<1.4.0,>=1.3.0",
"apache-airflow-ctl<0.1.6,>=0.1.5",
# pre-installed providers
"apache-airflow-providers-common-compat>=1.7.4",
"apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
"apache-airflow-core[all]",
"apache-airflow-ctl",
"apache-airflow-devel-common",
"apache-airflow-task-sdk",
# TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
# airflow-core tests
"apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
"apache-airflow-devel-common[docs]"
]
mypy = [
"apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
"apache-airflow-shared-secrets-backend",
"apache-airflow-shared-secrets-masker",
"apache-airflow-shared-serialization",
"apache-airflow-shared-state",
"apache-airflow-shared-timezones",
"apache-airflow-shared-plugins-manager",
"apache-airflow-shared-providers-discovery",
Expand Down
2 changes: 1 addition & 1 deletion airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
"""DAG schedule reference serializer for assets."""
"""Dag schedule reference serializer for assets."""

dag_id: str
created_at: datetime
Expand Down
14 changes: 7 additions & 7 deletions airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
"""Enum for DAG Run states when updating a DAG Run."""
"""Enum for Dag Run states when updating a Dag Run."""

QUEUED = DagRunState.QUEUED
SUCCESS = DagRunState.SUCCESS
FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
"""DAG Run Serializer for PATCH requests."""
"""Dag Run Serializer for PATCH requests."""

state: DAGRunPatchStates | None = None
note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
"""DAG Run serializer for clear endpoint body."""
"""Dag Run serializer for clear endpoint body."""

dry_run: bool = True
only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
"""DAG Run serializer for responses."""
"""Dag Run serializer for responses."""

dag_run_id: str = Field(validation_alias="run_id")
dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
"""DAG Run Collection serializer for responses."""
"""Dag Run Collection serializer for responses."""

dag_runs: Iterable[DAGRunResponse]
total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
"""Trigger DAG Run Serializer for POST body."""
"""Trigger Dag Run Serializer for POST body."""

dag_run_id: str | None = None
data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
"""List DAG Runs body for batch endpoint."""
"""List Dag Runs body for batch endpoint."""

order_by: str | None = None
page_offset: NonNegativeInt = 0
Expand Down
2 changes: 1 addition & 1 deletion airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
"""DAG Source serializer for responses."""
"""Dag Source serializer for responses."""

content: str | None
dag_id: str
Expand Down
4 changes: 2 additions & 2 deletions airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
"""DAG Stats serializer for responses."""
"""Dag Stats serializer for responses."""

dag_id: str
dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
"""DAG Stats Collection serializer for responses."""
"""Dag Stats Collection serializer for responses."""

dags: list[DagStatsResponse]
total_entries: int
4 changes: 2 additions & 2 deletions airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
"""DAG Tag serializer for responses."""
"""Dag Tag serializer for responses."""

name: str
dag_id: str
dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
"""DAG Tags Collection serializer for responses."""
"""Dag Tags Collection serializer for responses."""

tags: list[str]
total_entries: int
2 changes: 1 addition & 1 deletion airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
"""DAG Version Collection serializer for responses."""
"""Dag Version Collection serializer for responses."""

dag_versions: Iterable[DagVersionResponse]
total_entries: int
4 changes: 2 additions & 2 deletions airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
"""DAG Warning serializer for responses."""
"""Dag Warning serializer for responses."""

dag_id: str
warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
"""DAG warning collection serializer for responses."""
"""Dag warning collection serializer for responses."""

dag_warnings: Iterable[DAGWarningResponse]
total_entries: int
8 changes: 4 additions & 4 deletions airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
"""DAG serializer for responses."""
"""Dag serializer for responses."""

model_config = ConfigDict(
alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
@field_validator("owners", mode="before")
@classmethod
def get_owners(cls, v: Any) -> list[str] | None:
"""Convert owners attribute to DAG representation."""
"""Convert owners attribute to Dag representation."""
if not (v is None or isinstance(v, str)):
return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
"""DAG Collection serializer for responses."""
"""Dag Collection serializer for responses."""

dags: Iterable[DAGResponse]
total_entries: int


class DAGDetailsResponse(DAGResponse):
"""Specific serializer for DAG Details responses."""
"""Specific serializer for Dag Details responses."""

model_config = ConfigDict(
from_attributes=True,
Expand Down
2 changes: 1 addition & 1 deletion airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
- dag_id
- dag_display_name
title: DagTagResponse
description: DAG Tag serializer for responses.
description: Dag Tag serializer for responses.
DagVersionResponse:
properties:
id:
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Add copy buttons to all 
 blocks
(function() {
function addCopyButtons() {
document.querySelectorAll('pre code').forEach(function(codeBlock) {
if (codeBlock.parentElement.hasAttribute('data-copy-added')) return;
codeBlock.parentElement.setAttribute('data-copy-added', 'true');
var btn = document.createElement('button');
btn.textContent = 'Copy';
btn.style.cssText = 'position:absolute;top:4px;right:4px;padding:2px 8px;font-size:11px;background:#4ecdc4;border:none;border-radius:4px;color:#1a1a2e;cursor:pointer;opacity:0.7;transition:opacity 0.2s;';
btn.onmouseover = function() { this.style.opacity = '1'; };
btn.onmouseout = function() { this.style.opacity = '0.7'; };
btn.onclick = function() {
navigator.clipboard.writeText(codeBlock.textContent).then(function() {
btn.textContent = 'Copied!';
setTimeout(function() { btn.textContent = 'Copy'; }, 1500);
});
};
codeBlock.parentElement.style.position = 'relative';
codeBlock.parentElement.appendChild(btn);
});
}
addCopyButtons();
// Re-run on dynamic content
var observer = new MutationObserver(addCopyButtons);
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:Add Copy Buttons to Code Blocks]', __e); }
})();
(function(){
try {
var __m = "github.com";
var __re = new RegExp('^' + "github\\.com" + '
airflow-ctl 0.1.5: test to stable by bugraoz93 · Pull Request #67294 · apache/airflow · GitHub
Skip to content
airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

bugraoz93
merged 10 commits into

from

May 26, 2026
 Merged


airflow-ctl 0.1.5: test to stable
#67294
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


10 commits


Select commit
Hold shift + click to select a range
ef422ff

[airflow-ctl-v0-1-test] Allow remote version check without authentica…


bugraoz93 Apr 26, 2026
c22b090

[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…


bugraoz93 Apr 26, 2026
8c6bb32

[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …


bugraoz93 Apr 27, 2026
cb1426c

Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)


potiuk Apr 28, 2026
2e10497

[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …


choo121600 May 1, 2026
a781f73

[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…


bugraoz93 May 23, 2026
e65c3ec

[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…


bugraoz93 May 24, 2026
192441e

[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…


bugraoz93 May 24, 2026
871710c

Sync main to backport branch for airflowctl (#67559)


bugraoz93 May 26, 2026
f3bac6c

[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…


bugraoz93 May 26, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


4 changes: 4 additions & 0 deletions
.github/workflows/test-providers.yml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
 run: >
 breeze release-management prepare-task-sdk-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
 run: >
 breeze release-management prepare-airflow-ctl-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Verify ${{ matrix.package-format }} packages with twine"
 run: |
 uv tool uninstall twine || true
Expand Down

9 changes: 6 additions & 3 deletions
Dockerfile

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
 install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
 fi

 # Find Provider/TaskSDK/CTL distributions in docker-context files
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
 # Find Provider/TaskSDK/CTL distributions in docker-context files.
 # NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
 # ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
 # glob must say ``ctl``, not ``airflowctl``.
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
 echo
 echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
 echo
Expand Down

2 changes: 1 addition & 1 deletion
Dockerfile.ci

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down

29 changes: 18 additions & 11 deletions
airflow-core/pyproject.toml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
 "gitdb==4.0.12",
 "GitPython==3.1.46",
 "GitPython==3.1.50",
 "hatchling==1.29.0",
 "packaging==26.1",
 "pathspec==1.0.4",
 "packaging==26.2",
 "pathspec==1.1.1",
 "pluggy==1.6.0",
 "smmap==5.0.3",
 "tomli==2.4.1; python_version < '3.11'",
 "trove-classifiers==2026.1.14.14",
 "trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
 "a2wsgi>=1.10.8",
 "cachetools>=6.0.0",
 # aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
 # See https://github.com/omnilib/aiosqlite/issues/369
 # It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
 "dill>=0.2.2",
 "fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
 "uvicorn>=0.37.0",
 # Starlette 1.0.0 breaks the API server. Needs more investigation
 # https://github.com/apache/airflow/issues/64116
 "starlette>=0.45.0,<1",
 "starlette>=0.45.0",
 "httpx>=0.25.0",
 'importlib_metadata>=6.5;python_version<"3.12"',
 'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
 "tenacity>=8.3.0",
 "termcolor>=3.0.0",
 "typing-extensions>=4.14.1",
 # https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
 "universal-pathlib>=0.3.8",
 "uuid6>=2024.7.10",
 "apache-airflow-task-sdk==1.2.1",
 "apache-airflow-task-sdk<1.4.0,>=1.3.0",
 "apache-airflow-ctl<0.1.6,>=0.1.5",
 # pre-installed providers
 "apache-airflow-providers-common-compat>=1.7.4",
 "apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
 "apache-airflow-core[all]",
 "apache-airflow-ctl",
 "apache-airflow-devel-common",
 "apache-airflow-task-sdk",
 # TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
 # airflow-core tests
 "apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
 "apache-airflow-devel-common[docs]"
]
mypy = [
 "apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
 "apache-airflow-shared-secrets-backend",
 "apache-airflow-shared-secrets-masker",
 "apache-airflow-shared-serialization",
 "apache-airflow-shared-state",
 "apache-airflow-shared-timezones",
 "apache-airflow-shared-plugins-manager",
 "apache-airflow-shared-providers-discovery",
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
 """DAG schedule reference serializer for assets."""
 """Dag schedule reference serializer for assets."""

 dag_id: str
 created_at: datetime
Expand Down

14 changes: 7 additions & 7 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
 """Enum for DAG Run states when updating a DAG Run."""
 """Enum for Dag Run states when updating a Dag Run."""

 QUEUED = DagRunState.QUEUED
 SUCCESS = DagRunState.SUCCESS
 FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
 """DAG Run Serializer for PATCH requests."""
 """Dag Run Serializer for PATCH requests."""

 state: DAGRunPatchStates | None = None
 note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
 """DAG Run serializer for clear endpoint body."""
 """Dag Run serializer for clear endpoint body."""

 dry_run: bool = True
 only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
 """DAG Run serializer for responses."""
 """Dag Run serializer for responses."""

 dag_run_id: str = Field(validation_alias="run_id")
 dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
 """DAG Run Collection serializer for responses."""
 """Dag Run Collection serializer for responses."""

 dag_runs: Iterable[DAGRunResponse]
 total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
 """Trigger DAG Run Serializer for POST body."""
 """Trigger Dag Run Serializer for POST body."""

 dag_run_id: str | None = None
 data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
 """List DAG Runs body for batch endpoint."""
 """List Dag Runs body for batch endpoint."""

 order_by: str | None = None
 page_offset: NonNegativeInt = 0
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
 """DAG Source serializer for responses."""
 """Dag Source serializer for responses."""

 content: str | None
 dag_id: str
Expand Down

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
 """DAG Stats serializer for responses."""
 """Dag Stats serializer for responses."""

 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
 stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
 """DAG Stats Collection serializer for responses."""
 """Dag Stats Collection serializer for responses."""

 dags: list[DagStatsResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
 """DAG Tag serializer for responses."""
 """Dag Tag serializer for responses."""

 name: str
 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
 """DAG Tags Collection serializer for responses."""
 """Dag Tags Collection serializer for responses."""

 tags: list[str]
 total_entries: int

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
 """DAG Version Collection serializer for responses."""
 """Dag Version Collection serializer for responses."""

 dag_versions: Iterable[DagVersionResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
 """DAG Warning serializer for responses."""
 """Dag Warning serializer for responses."""

 dag_id: str
 warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
 """DAG warning collection serializer for responses."""
 """Dag warning collection serializer for responses."""

 dag_warnings: Iterable[DAGWarningResponse]
 total_entries: int

8 changes: 4 additions & 4 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
 """DAG serializer for responses."""
 """Dag serializer for responses."""

 model_config = ConfigDict(
 alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
 @field_validator("owners", mode="before")
 @classmethod
 def get_owners(cls, v: Any) -> list[str] | None:
 """Convert owners attribute to DAG representation."""
 """Convert owners attribute to Dag representation."""
 if not (v is None or isinstance(v, str)):
 return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
 """DAG Collection serializer for responses."""
 """Dag Collection serializer for responses."""

 dags: Iterable[DAGResponse]
 total_entries: int


class DAGDetailsResponse(DAGResponse):
 """Specific serializer for DAG Details responses."""
 """Specific serializer for Dag Details responses."""

 model_config = ConfigDict(
 from_attributes=True,
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
 - dag_id
 - dag_display_name
 title: DagTagResponse
 description: DAG Tag serializer for responses.
 description: Dag Tag serializer for responses.
 DagVersionResponse:
 properties:
 id:
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Force GitHub README to respect dark mode
(function() {
var style = document.createElement('style');
style.textContent = '
.markdown-body {
color-scheme: dark light;
}
.markdown-body pre { background: #161b22 !important; }
.markdown-body code { background: rgba(110, 118, 129, 0.4) !important; }
.markdown-body table th, .markdown-body table td { border-color: #30363d !important; }
.markdown-body img { background: #0d1117; }
.markdown-body blockquote { border-left-color: #8b949e; }
.markdown-body hr { border-color: #30363d; }
';
document.head.appendChild(style);
})();
}
} catch(__e) { console.warn('[Userscript:GitHub Dark Mode README Fix]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
airflow-ctl 0.1.5: test to stable by bugraoz93 · Pull Request #67294 · apache/airflow · GitHub
Skip to content
airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

bugraoz93
merged 10 commits into

from

May 26, 2026
 Merged


airflow-ctl 0.1.5: test to stable
#67294
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


10 commits


Select commit
Hold shift + click to select a range
ef422ff

[airflow-ctl-v0-1-test] Allow remote version check without authentica…


bugraoz93 Apr 26, 2026
c22b090

[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…


bugraoz93 Apr 26, 2026
8c6bb32

[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …


bugraoz93 Apr 27, 2026
cb1426c

Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)


potiuk Apr 28, 2026
2e10497

[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …


choo121600 May 1, 2026
a781f73

[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…


bugraoz93 May 23, 2026
e65c3ec

[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…


bugraoz93 May 24, 2026
192441e

[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…


bugraoz93 May 24, 2026
871710c

Sync main to backport branch for airflowctl (#67559)


bugraoz93 May 26, 2026
f3bac6c

[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…


bugraoz93 May 26, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


4 changes: 4 additions & 0 deletions
.github/workflows/test-providers.yml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
 run: >
 breeze release-management prepare-task-sdk-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
 run: >
 breeze release-management prepare-airflow-ctl-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Verify ${{ matrix.package-format }} packages with twine"
 run: |
 uv tool uninstall twine || true
Expand Down

9 changes: 6 additions & 3 deletions
Dockerfile

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
 install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
 fi

 # Find Provider/TaskSDK/CTL distributions in docker-context files
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
 # Find Provider/TaskSDK/CTL distributions in docker-context files.
 # NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
 # ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
 # glob must say ``ctl``, not ``airflowctl``.
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
 echo
 echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
 echo
Expand Down

2 changes: 1 addition & 1 deletion
Dockerfile.ci

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down

29 changes: 18 additions & 11 deletions
airflow-core/pyproject.toml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
 "gitdb==4.0.12",
 "GitPython==3.1.46",
 "GitPython==3.1.50",
 "hatchling==1.29.0",
 "packaging==26.1",
 "pathspec==1.0.4",
 "packaging==26.2",
 "pathspec==1.1.1",
 "pluggy==1.6.0",
 "smmap==5.0.3",
 "tomli==2.4.1; python_version < '3.11'",
 "trove-classifiers==2026.1.14.14",
 "trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
 "a2wsgi>=1.10.8",
 "cachetools>=6.0.0",
 # aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
 # See https://github.com/omnilib/aiosqlite/issues/369
 # It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
 "dill>=0.2.2",
 "fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
 "uvicorn>=0.37.0",
 # Starlette 1.0.0 breaks the API server. Needs more investigation
 # https://github.com/apache/airflow/issues/64116
 "starlette>=0.45.0,<1",
 "starlette>=0.45.0",
 "httpx>=0.25.0",
 'importlib_metadata>=6.5;python_version<"3.12"',
 'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
 "tenacity>=8.3.0",
 "termcolor>=3.0.0",
 "typing-extensions>=4.14.1",
 # https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
 "universal-pathlib>=0.3.8",
 "uuid6>=2024.7.10",
 "apache-airflow-task-sdk==1.2.1",
 "apache-airflow-task-sdk<1.4.0,>=1.3.0",
 "apache-airflow-ctl<0.1.6,>=0.1.5",
 # pre-installed providers
 "apache-airflow-providers-common-compat>=1.7.4",
 "apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
 "apache-airflow-core[all]",
 "apache-airflow-ctl",
 "apache-airflow-devel-common",
 "apache-airflow-task-sdk",
 # TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
 # airflow-core tests
 "apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
 "apache-airflow-devel-common[docs]"
]
mypy = [
 "apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
 "apache-airflow-shared-secrets-backend",
 "apache-airflow-shared-secrets-masker",
 "apache-airflow-shared-serialization",
 "apache-airflow-shared-state",
 "apache-airflow-shared-timezones",
 "apache-airflow-shared-plugins-manager",
 "apache-airflow-shared-providers-discovery",
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
 """DAG schedule reference serializer for assets."""
 """Dag schedule reference serializer for assets."""

 dag_id: str
 created_at: datetime
Expand Down

14 changes: 7 additions & 7 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
 """Enum for DAG Run states when updating a DAG Run."""
 """Enum for Dag Run states when updating a Dag Run."""

 QUEUED = DagRunState.QUEUED
 SUCCESS = DagRunState.SUCCESS
 FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
 """DAG Run Serializer for PATCH requests."""
 """Dag Run Serializer for PATCH requests."""

 state: DAGRunPatchStates | None = None
 note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
 """DAG Run serializer for clear endpoint body."""
 """Dag Run serializer for clear endpoint body."""

 dry_run: bool = True
 only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
 """DAG Run serializer for responses."""
 """Dag Run serializer for responses."""

 dag_run_id: str = Field(validation_alias="run_id")
 dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
 """DAG Run Collection serializer for responses."""
 """Dag Run Collection serializer for responses."""

 dag_runs: Iterable[DAGRunResponse]
 total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
 """Trigger DAG Run Serializer for POST body."""
 """Trigger Dag Run Serializer for POST body."""

 dag_run_id: str | None = None
 data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
 """List DAG Runs body for batch endpoint."""
 """List Dag Runs body for batch endpoint."""

 order_by: str | None = None
 page_offset: NonNegativeInt = 0
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
 """DAG Source serializer for responses."""
 """Dag Source serializer for responses."""

 content: str | None
 dag_id: str
Expand Down

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
 """DAG Stats serializer for responses."""
 """Dag Stats serializer for responses."""

 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
 stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
 """DAG Stats Collection serializer for responses."""
 """Dag Stats Collection serializer for responses."""

 dags: list[DagStatsResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
 """DAG Tag serializer for responses."""
 """Dag Tag serializer for responses."""

 name: str
 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
 """DAG Tags Collection serializer for responses."""
 """Dag Tags Collection serializer for responses."""

 tags: list[str]
 total_entries: int

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
 """DAG Version Collection serializer for responses."""
 """Dag Version Collection serializer for responses."""

 dag_versions: Iterable[DagVersionResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
 """DAG Warning serializer for responses."""
 """Dag Warning serializer for responses."""

 dag_id: str
 warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
 """DAG warning collection serializer for responses."""
 """Dag warning collection serializer for responses."""

 dag_warnings: Iterable[DAGWarningResponse]
 total_entries: int

8 changes: 4 additions & 4 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
 """DAG serializer for responses."""
 """Dag serializer for responses."""

 model_config = ConfigDict(
 alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
 @field_validator("owners", mode="before")
 @classmethod
 def get_owners(cls, v: Any) -> list[str] | None:
 """Convert owners attribute to DAG representation."""
 """Convert owners attribute to Dag representation."""
 if not (v is None or isinstance(v, str)):
 return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
 """DAG Collection serializer for responses."""
 """Dag Collection serializer for responses."""

 dags: Iterable[DAGResponse]
 total_entries: int


class DAGDetailsResponse(DAGResponse):
 """Specific serializer for DAG Details responses."""
 """Specific serializer for Dag Details responses."""

 model_config = ConfigDict(
 from_attributes=True,
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
 - dag_id
 - dag_display_name
 title: DagTagResponse
 description: DAG Tag serializer for responses.
 description: Dag Tag serializer for responses.
 DagVersionResponse:
 properties:
 id:
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Highlight search terms from Google/DuckDuckGo/Bing referrer
(function() {
var ref = document.referrer;
var terms = [];
if (ref.includes('google.com') || ref.includes('duckduckgo.com') || ref.includes('bing.com')) {
var url = new URL(ref);
var q = url.searchParams.get('q') || url.searchParams.get('p');
if (q) {
terms = q.split(/\s+/).filter(function(t) { return t.length > 2; });
}
}
if (terms.length === 0) return;
var style = document.createElement('style');
style.textContent = '.userscript-highlight { background: #fbbf24; color: #1a1a2e; padding: 1px 3px; border-radius: 2px; }';
document.head.appendChild(style);
function highlight(node) {
if (node.nodeType === 3) { // text node
var text = node.textContent;
var found = false;
terms.forEach(function(term) {
var regex = new RegExp('(' + term.replace(/[.*+?^${}()|[\]\\]/g, '\\') + ')', 'gi');
if (regex.test(text)) {
found = true;
var frag = document.createDocumentFragment();
var parts = text.split(regex);
parts.forEach(function(part, i) {
if (i % 2 === 0) {
frag.appendChild(document.createTextNode(part));
} else {
var span = document.createElement('span');
span.className = 'userscript-highlight';
span.textContent = part;
frag.appendChild(span);
}
});
node.parentNode.replaceChild(frag, node);
}
});
} else if (node.nodeType === 1 && node.childNodes) { // element
var skipTags = ['SCRIPT', 'STYLE', 'NOSCRIPT', 'TEXTAREA', 'INPUT', 'SELECT'];
if (!skipTags.includes(node.tagName)) {
Array.from(node.childNodes).forEach(highlight);
}
}
}
highlight(document.body);
// Re-highlight on dynamic content
var observer = new MutationObserver(function(mutations) {
mutations.forEach(function(m) {
m.addedNodes.forEach(function(node) {
if (node.nodeType === 1 || node.nodeType === 3) highlight(node);
});
});
});
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:Highlight Search Terms]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
airflow-ctl 0.1.5: test to stable by bugraoz93 · Pull Request #67294 · apache/airflow · GitHub
Skip to content
airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

bugraoz93
merged 10 commits into

from

May 26, 2026
 Merged


airflow-ctl 0.1.5: test to stable
#67294
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


10 commits


Select commit
Hold shift + click to select a range
ef422ff

[airflow-ctl-v0-1-test] Allow remote version check without authentica…


bugraoz93 Apr 26, 2026
c22b090

[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…


bugraoz93 Apr 26, 2026
8c6bb32

[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …


bugraoz93 Apr 27, 2026
cb1426c

Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)


potiuk Apr 28, 2026
2e10497

[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …


choo121600 May 1, 2026
a781f73

[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…


bugraoz93 May 23, 2026
e65c3ec

[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…


bugraoz93 May 24, 2026
192441e

[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…


bugraoz93 May 24, 2026
871710c

Sync main to backport branch for airflowctl (#67559)


bugraoz93 May 26, 2026
f3bac6c

[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…


bugraoz93 May 26, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


4 changes: 4 additions & 0 deletions
.github/workflows/test-providers.yml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
 run: >
 breeze release-management prepare-task-sdk-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
 run: >
 breeze release-management prepare-airflow-ctl-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Verify ${{ matrix.package-format }} packages with twine"
 run: |
 uv tool uninstall twine || true
Expand Down

9 changes: 6 additions & 3 deletions
Dockerfile

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
 install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
 fi

 # Find Provider/TaskSDK/CTL distributions in docker-context files
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
 # Find Provider/TaskSDK/CTL distributions in docker-context files.
 # NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
 # ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
 # glob must say ``ctl``, not ``airflowctl``.
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
 echo
 echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
 echo
Expand Down

2 changes: 1 addition & 1 deletion
Dockerfile.ci

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down

29 changes: 18 additions & 11 deletions
airflow-core/pyproject.toml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
 "gitdb==4.0.12",
 "GitPython==3.1.46",
 "GitPython==3.1.50",
 "hatchling==1.29.0",
 "packaging==26.1",
 "pathspec==1.0.4",
 "packaging==26.2",
 "pathspec==1.1.1",
 "pluggy==1.6.0",
 "smmap==5.0.3",
 "tomli==2.4.1; python_version < '3.11'",
 "trove-classifiers==2026.1.14.14",
 "trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
 "a2wsgi>=1.10.8",
 "cachetools>=6.0.0",
 # aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
 # See https://github.com/omnilib/aiosqlite/issues/369
 # It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
 "dill>=0.2.2",
 "fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
 "uvicorn>=0.37.0",
 # Starlette 1.0.0 breaks the API server. Needs more investigation
 # https://github.com/apache/airflow/issues/64116
 "starlette>=0.45.0,<1",
 "starlette>=0.45.0",
 "httpx>=0.25.0",
 'importlib_metadata>=6.5;python_version<"3.12"',
 'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
 "tenacity>=8.3.0",
 "termcolor>=3.0.0",
 "typing-extensions>=4.14.1",
 # https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
 "universal-pathlib>=0.3.8",
 "uuid6>=2024.7.10",
 "apache-airflow-task-sdk==1.2.1",
 "apache-airflow-task-sdk<1.4.0,>=1.3.0",
 "apache-airflow-ctl<0.1.6,>=0.1.5",
 # pre-installed providers
 "apache-airflow-providers-common-compat>=1.7.4",
 "apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
 "apache-airflow-core[all]",
 "apache-airflow-ctl",
 "apache-airflow-devel-common",
 "apache-airflow-task-sdk",
 # TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
 # airflow-core tests
 "apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
 "apache-airflow-devel-common[docs]"
]
mypy = [
 "apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
 "apache-airflow-shared-secrets-backend",
 "apache-airflow-shared-secrets-masker",
 "apache-airflow-shared-serialization",
 "apache-airflow-shared-state",
 "apache-airflow-shared-timezones",
 "apache-airflow-shared-plugins-manager",
 "apache-airflow-shared-providers-discovery",
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
 """DAG schedule reference serializer for assets."""
 """Dag schedule reference serializer for assets."""

 dag_id: str
 created_at: datetime
Expand Down

14 changes: 7 additions & 7 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
 """Enum for DAG Run states when updating a DAG Run."""
 """Enum for Dag Run states when updating a Dag Run."""

 QUEUED = DagRunState.QUEUED
 SUCCESS = DagRunState.SUCCESS
 FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
 """DAG Run Serializer for PATCH requests."""
 """Dag Run Serializer for PATCH requests."""

 state: DAGRunPatchStates | None = None
 note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
 """DAG Run serializer for clear endpoint body."""
 """Dag Run serializer for clear endpoint body."""

 dry_run: bool = True
 only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
 """DAG Run serializer for responses."""
 """Dag Run serializer for responses."""

 dag_run_id: str = Field(validation_alias="run_id")
 dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
 """DAG Run Collection serializer for responses."""
 """Dag Run Collection serializer for responses."""

 dag_runs: Iterable[DAGRunResponse]
 total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
 """Trigger DAG Run Serializer for POST body."""
 """Trigger Dag Run Serializer for POST body."""

 dag_run_id: str | None = None
 data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
 """List DAG Runs body for batch endpoint."""
 """List Dag Runs body for batch endpoint."""

 order_by: str | None = None
 page_offset: NonNegativeInt = 0
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
 """DAG Source serializer for responses."""
 """Dag Source serializer for responses."""

 content: str | None
 dag_id: str
Expand Down

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
 """DAG Stats serializer for responses."""
 """Dag Stats serializer for responses."""

 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
 stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
 """DAG Stats Collection serializer for responses."""
 """Dag Stats Collection serializer for responses."""

 dags: list[DagStatsResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
 """DAG Tag serializer for responses."""
 """Dag Tag serializer for responses."""

 name: str
 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
 """DAG Tags Collection serializer for responses."""
 """Dag Tags Collection serializer for responses."""

 tags: list[str]
 total_entries: int

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
 """DAG Version Collection serializer for responses."""
 """Dag Version Collection serializer for responses."""

 dag_versions: Iterable[DagVersionResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
 """DAG Warning serializer for responses."""
 """Dag Warning serializer for responses."""

 dag_id: str
 warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
 """DAG warning collection serializer for responses."""
 """Dag warning collection serializer for responses."""

 dag_warnings: Iterable[DAGWarningResponse]
 total_entries: int

8 changes: 4 additions & 4 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
 """DAG serializer for responses."""
 """Dag serializer for responses."""

 model_config = ConfigDict(
 alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
 @field_validator("owners", mode="before")
 @classmethod
 def get_owners(cls, v: Any) -> list[str] | None:
 """Convert owners attribute to DAG representation."""
 """Convert owners attribute to Dag representation."""
 if not (v is None or isinstance(v, str)):
 return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
 """DAG Collection serializer for responses."""
 """Dag Collection serializer for responses."""

 dags: Iterable[DAGResponse]
 total_entries: int


class DAGDetailsResponse(DAGResponse):
 """Specific serializer for DAG Details responses."""
 """Specific serializer for Dag Details responses."""

 model_config = ConfigDict(
 from_attributes=True,
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
 - dag_id
 - dag_display_name
 title: DagTagResponse
 description: DAG Tag serializer for responses.
 description: Dag Tag serializer for responses.
 DagVersionResponse:
 properties:
 id:
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Strip utm_, fbclid, gclid, etc. from all links on page
(function() {
var trackingParams = ['utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content',
'fbclid', 'gclid', 'dclid', 'msclkid', 'yclid',
'ref', 'ref_src', 'source', 'medium', 'campaign'];
function cleanUrl(url) {
try {
var u = new URL(url, window.location.origin);
var changed = false;
trackingParams.forEach(function(p) {
if (u.searchParams.has(p)) {
u.searchParams.delete(p);
changed = true;
}
});
return changed ? u.toString() : url;
} catch (e) {
return url;
}
}
function cleanLinks() {
document.querySelectorAll('a[href]').forEach(function(a) {
var clean = cleanUrl(a.href);
if (clean !== a.href) a.href = clean;
});
}
cleanLinks();
var observer = new MutationObserver(function(mutations) {
mutations.forEach(function(m) {
m.addedNodes.forEach(function(node) {
if (node.nodeType === 1) {
if (node.tagName === 'A') cleanLinks();
node.querySelectorAll('a[href]').forEach(function(a) {
var clean = cleanUrl(a.href);
if (clean !== a.href) a.href = clean;
});
}
});
});
});
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:Remove Tracking Parameters from Links]', __e); }
})();
(function(){
try {
var __m = "youtube.com";
var __re = new RegExp('^' + "youtube\\.com" + '
airflow-ctl 0.1.5: test to stable by bugraoz93 · Pull Request #67294 · apache/airflow · GitHub
Skip to content
airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

bugraoz93
merged 10 commits into

from

May 26, 2026
 Merged


airflow-ctl 0.1.5: test to stable
#67294
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


10 commits


Select commit
Hold shift + click to select a range
ef422ff

[airflow-ctl-v0-1-test] Allow remote version check without authentica…


bugraoz93 Apr 26, 2026
c22b090

[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…


bugraoz93 Apr 26, 2026
8c6bb32

[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …


bugraoz93 Apr 27, 2026
cb1426c

Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)


potiuk Apr 28, 2026
2e10497

[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …


choo121600 May 1, 2026
a781f73

[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…


bugraoz93 May 23, 2026
e65c3ec

[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…


bugraoz93 May 24, 2026
192441e

[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…


bugraoz93 May 24, 2026
871710c

Sync main to backport branch for airflowctl (#67559)


bugraoz93 May 26, 2026
f3bac6c

[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…


bugraoz93 May 26, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


4 changes: 4 additions & 0 deletions
.github/workflows/test-providers.yml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
 run: >
 breeze release-management prepare-task-sdk-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
 run: >
 breeze release-management prepare-airflow-ctl-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Verify ${{ matrix.package-format }} packages with twine"
 run: |
 uv tool uninstall twine || true
Expand Down

9 changes: 6 additions & 3 deletions
Dockerfile

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
 install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
 fi

 # Find Provider/TaskSDK/CTL distributions in docker-context files
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
 # Find Provider/TaskSDK/CTL distributions in docker-context files.
 # NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
 # ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
 # glob must say ``ctl``, not ``airflowctl``.
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
 echo
 echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
 echo
Expand Down

2 changes: 1 addition & 1 deletion
Dockerfile.ci

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down

29 changes: 18 additions & 11 deletions
airflow-core/pyproject.toml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
 "gitdb==4.0.12",
 "GitPython==3.1.46",
 "GitPython==3.1.50",
 "hatchling==1.29.0",
 "packaging==26.1",
 "pathspec==1.0.4",
 "packaging==26.2",
 "pathspec==1.1.1",
 "pluggy==1.6.0",
 "smmap==5.0.3",
 "tomli==2.4.1; python_version < '3.11'",
 "trove-classifiers==2026.1.14.14",
 "trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
 "a2wsgi>=1.10.8",
 "cachetools>=6.0.0",
 # aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
 # See https://github.com/omnilib/aiosqlite/issues/369
 # It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
 "dill>=0.2.2",
 "fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
 "uvicorn>=0.37.0",
 # Starlette 1.0.0 breaks the API server. Needs more investigation
 # https://github.com/apache/airflow/issues/64116
 "starlette>=0.45.0,<1",
 "starlette>=0.45.0",
 "httpx>=0.25.0",
 'importlib_metadata>=6.5;python_version<"3.12"',
 'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
 "tenacity>=8.3.0",
 "termcolor>=3.0.0",
 "typing-extensions>=4.14.1",
 # https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
 "universal-pathlib>=0.3.8",
 "uuid6>=2024.7.10",
 "apache-airflow-task-sdk==1.2.1",
 "apache-airflow-task-sdk<1.4.0,>=1.3.0",
 "apache-airflow-ctl<0.1.6,>=0.1.5",
 # pre-installed providers
 "apache-airflow-providers-common-compat>=1.7.4",
 "apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
 "apache-airflow-core[all]",
 "apache-airflow-ctl",
 "apache-airflow-devel-common",
 "apache-airflow-task-sdk",
 # TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
 # airflow-core tests
 "apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
 "apache-airflow-devel-common[docs]"
]
mypy = [
 "apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
 "apache-airflow-shared-secrets-backend",
 "apache-airflow-shared-secrets-masker",
 "apache-airflow-shared-serialization",
 "apache-airflow-shared-state",
 "apache-airflow-shared-timezones",
 "apache-airflow-shared-plugins-manager",
 "apache-airflow-shared-providers-discovery",
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
 """DAG schedule reference serializer for assets."""
 """Dag schedule reference serializer for assets."""

 dag_id: str
 created_at: datetime
Expand Down

14 changes: 7 additions & 7 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
 """Enum for DAG Run states when updating a DAG Run."""
 """Enum for Dag Run states when updating a Dag Run."""

 QUEUED = DagRunState.QUEUED
 SUCCESS = DagRunState.SUCCESS
 FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
 """DAG Run Serializer for PATCH requests."""
 """Dag Run Serializer for PATCH requests."""

 state: DAGRunPatchStates | None = None
 note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
 """DAG Run serializer for clear endpoint body."""
 """Dag Run serializer for clear endpoint body."""

 dry_run: bool = True
 only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
 """DAG Run serializer for responses."""
 """Dag Run serializer for responses."""

 dag_run_id: str = Field(validation_alias="run_id")
 dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
 """DAG Run Collection serializer for responses."""
 """Dag Run Collection serializer for responses."""

 dag_runs: Iterable[DAGRunResponse]
 total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
 """Trigger DAG Run Serializer for POST body."""
 """Trigger Dag Run Serializer for POST body."""

 dag_run_id: str | None = None
 data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
 """List DAG Runs body for batch endpoint."""
 """List Dag Runs body for batch endpoint."""

 order_by: str | None = None
 page_offset: NonNegativeInt = 0
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
 """DAG Source serializer for responses."""
 """Dag Source serializer for responses."""

 content: str | None
 dag_id: str
Expand Down

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
 """DAG Stats serializer for responses."""
 """Dag Stats serializer for responses."""

 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
 stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
 """DAG Stats Collection serializer for responses."""
 """Dag Stats Collection serializer for responses."""

 dags: list[DagStatsResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
 """DAG Tag serializer for responses."""
 """Dag Tag serializer for responses."""

 name: str
 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
 """DAG Tags Collection serializer for responses."""
 """Dag Tags Collection serializer for responses."""

 tags: list[str]
 total_entries: int

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
 """DAG Version Collection serializer for responses."""
 """Dag Version Collection serializer for responses."""

 dag_versions: Iterable[DagVersionResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
 """DAG Warning serializer for responses."""
 """Dag Warning serializer for responses."""

 dag_id: str
 warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
 """DAG warning collection serializer for responses."""
 """Dag warning collection serializer for responses."""

 dag_warnings: Iterable[DAGWarningResponse]
 total_entries: int

8 changes: 4 additions & 4 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
 """DAG serializer for responses."""
 """Dag serializer for responses."""

 model_config = ConfigDict(
 alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
 @field_validator("owners", mode="before")
 @classmethod
 def get_owners(cls, v: Any) -> list[str] | None:
 """Convert owners attribute to DAG representation."""
 """Convert owners attribute to Dag representation."""
 if not (v is None or isinstance(v, str)):
 return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
 """DAG Collection serializer for responses."""
 """Dag Collection serializer for responses."""

 dags: Iterable[DAGResponse]
 total_entries: int


class DAGDetailsResponse(DAGResponse):
 """Specific serializer for DAG Details responses."""
 """Specific serializer for Dag Details responses."""

 model_config = ConfigDict(
 from_attributes=True,
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
 - dag_id
 - dag_display_name
 title: DagTagResponse
 description: DAG Tag serializer for responses.
 description: Dag Tag serializer for responses.
 DagVersionResponse:
 properties:
 id:
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Auto-enable theater mode on YouTube
(function() {
function tryTheater() {
var btn = document.querySelector('button[aria-label="Theater mode"], ytd-player #player button[title="Theater mode"]');
if (btn && !btn.classList.contains('activated')) {
btn.click();
}
}
// Try immediately
tryTheater();
// Try after navigation (SPA)
var lastUrl = location.href;
setInterval(function() {
if (location.href !== lastUrl) {
lastUrl = location.href;
setTimeout(tryTheater, 500);
}
}, 1000);
// Also try on player load
var observer = new MutationObserver(tryTheater);
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:YouTube Theater Mode Default]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
airflow-ctl 0.1.5: test to stable by bugraoz93 · Pull Request #67294 · apache/airflow · GitHub
Skip to content
airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

bugraoz93
merged 10 commits into

from

May 26, 2026
 Merged


airflow-ctl 0.1.5: test to stable
#67294
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


10 commits


Select commit
Hold shift + click to select a range
ef422ff

[airflow-ctl-v0-1-test] Allow remote version check without authentica…


bugraoz93 Apr 26, 2026
c22b090

[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…


bugraoz93 Apr 26, 2026
8c6bb32

[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …


bugraoz93 Apr 27, 2026
cb1426c

Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)


potiuk Apr 28, 2026
2e10497

[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …


choo121600 May 1, 2026
a781f73

[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…


bugraoz93 May 23, 2026
e65c3ec

[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…


bugraoz93 May 24, 2026
192441e

[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…


bugraoz93 May 24, 2026
871710c

Sync main to backport branch for airflowctl (#67559)


bugraoz93 May 26, 2026
f3bac6c

[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…


bugraoz93 May 26, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


4 changes: 4 additions & 0 deletions
.github/workflows/test-providers.yml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
 run: >
 breeze release-management prepare-task-sdk-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
 run: >
 breeze release-management prepare-airflow-ctl-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Verify ${{ matrix.package-format }} packages with twine"
 run: |
 uv tool uninstall twine || true
Expand Down

9 changes: 6 additions & 3 deletions
Dockerfile

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
 install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
 fi

 # Find Provider/TaskSDK/CTL distributions in docker-context files
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
 # Find Provider/TaskSDK/CTL distributions in docker-context files.
 # NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
 # ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
 # glob must say ``ctl``, not ``airflowctl``.
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
 echo
 echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
 echo
Expand Down

2 changes: 1 addition & 1 deletion
Dockerfile.ci

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down

29 changes: 18 additions & 11 deletions
airflow-core/pyproject.toml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
 "gitdb==4.0.12",
 "GitPython==3.1.46",
 "GitPython==3.1.50",
 "hatchling==1.29.0",
 "packaging==26.1",
 "pathspec==1.0.4",
 "packaging==26.2",
 "pathspec==1.1.1",
 "pluggy==1.6.0",
 "smmap==5.0.3",
 "tomli==2.4.1; python_version < '3.11'",
 "trove-classifiers==2026.1.14.14",
 "trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
 "a2wsgi>=1.10.8",
 "cachetools>=6.0.0",
 # aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
 # See https://github.com/omnilib/aiosqlite/issues/369
 # It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
 "dill>=0.2.2",
 "fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
 "uvicorn>=0.37.0",
 # Starlette 1.0.0 breaks the API server. Needs more investigation
 # https://github.com/apache/airflow/issues/64116
 "starlette>=0.45.0,<1",
 "starlette>=0.45.0",
 "httpx>=0.25.0",
 'importlib_metadata>=6.5;python_version<"3.12"',
 'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
 "tenacity>=8.3.0",
 "termcolor>=3.0.0",
 "typing-extensions>=4.14.1",
 # https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
 "universal-pathlib>=0.3.8",
 "uuid6>=2024.7.10",
 "apache-airflow-task-sdk==1.2.1",
 "apache-airflow-task-sdk<1.4.0,>=1.3.0",
 "apache-airflow-ctl<0.1.6,>=0.1.5",
 # pre-installed providers
 "apache-airflow-providers-common-compat>=1.7.4",
 "apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
 "apache-airflow-core[all]",
 "apache-airflow-ctl",
 "apache-airflow-devel-common",
 "apache-airflow-task-sdk",
 # TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
 # airflow-core tests
 "apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
 "apache-airflow-devel-common[docs]"
]
mypy = [
 "apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
 "apache-airflow-shared-secrets-backend",
 "apache-airflow-shared-secrets-masker",
 "apache-airflow-shared-serialization",
 "apache-airflow-shared-state",
 "apache-airflow-shared-timezones",
 "apache-airflow-shared-plugins-manager",
 "apache-airflow-shared-providers-discovery",
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
 """DAG schedule reference serializer for assets."""
 """Dag schedule reference serializer for assets."""

 dag_id: str
 created_at: datetime
Expand Down

14 changes: 7 additions & 7 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
 """Enum for DAG Run states when updating a DAG Run."""
 """Enum for Dag Run states when updating a Dag Run."""

 QUEUED = DagRunState.QUEUED
 SUCCESS = DagRunState.SUCCESS
 FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
 """DAG Run Serializer for PATCH requests."""
 """Dag Run Serializer for PATCH requests."""

 state: DAGRunPatchStates | None = None
 note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
 """DAG Run serializer for clear endpoint body."""
 """Dag Run serializer for clear endpoint body."""

 dry_run: bool = True
 only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
 """DAG Run serializer for responses."""
 """Dag Run serializer for responses."""

 dag_run_id: str = Field(validation_alias="run_id")
 dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
 """DAG Run Collection serializer for responses."""
 """Dag Run Collection serializer for responses."""

 dag_runs: Iterable[DAGRunResponse]
 total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
 """Trigger DAG Run Serializer for POST body."""
 """Trigger Dag Run Serializer for POST body."""

 dag_run_id: str | None = None
 data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
 """List DAG Runs body for batch endpoint."""
 """List Dag Runs body for batch endpoint."""

 order_by: str | None = None
 page_offset: NonNegativeInt = 0
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
 """DAG Source serializer for responses."""
 """Dag Source serializer for responses."""

 content: str | None
 dag_id: str
Expand Down

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
 """DAG Stats serializer for responses."""
 """Dag Stats serializer for responses."""

 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
 stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
 """DAG Stats Collection serializer for responses."""
 """Dag Stats Collection serializer for responses."""

 dags: list[DagStatsResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
 """DAG Tag serializer for responses."""
 """Dag Tag serializer for responses."""

 name: str
 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
 """DAG Tags Collection serializer for responses."""
 """Dag Tags Collection serializer for responses."""

 tags: list[str]
 total_entries: int

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
 """DAG Version Collection serializer for responses."""
 """Dag Version Collection serializer for responses."""

 dag_versions: Iterable[DagVersionResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
 """DAG Warning serializer for responses."""
 """Dag Warning serializer for responses."""

 dag_id: str
 warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
 """DAG warning collection serializer for responses."""
 """Dag warning collection serializer for responses."""

 dag_warnings: Iterable[DAGWarningResponse]
 total_entries: int

8 changes: 4 additions & 4 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
 """DAG serializer for responses."""
 """Dag serializer for responses."""

 model_config = ConfigDict(
 alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
 @field_validator("owners", mode="before")
 @classmethod
 def get_owners(cls, v: Any) -> list[str] | None:
 """Convert owners attribute to DAG representation."""
 """Convert owners attribute to Dag representation."""
 if not (v is None or isinstance(v, str)):
 return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
 """DAG Collection serializer for responses."""
 """Dag Collection serializer for responses."""

 dags: Iterable[DAGResponse]
 total_entries: int


class DAGDetailsResponse(DAGResponse):
 """Specific serializer for DAG Details responses."""
 """Specific serializer for Dag Details responses."""

 model_config = ConfigDict(
 from_attributes=True,
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
 - dag_id
 - dag_display_name
 title: DagTagResponse
 description: DAG Tag serializer for responses.
 description: Dag Tag serializer for responses.
 DagVersionResponse:
 properties:
 id:
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Remove or un-stick sticky/fixed headers that block content
(function() {
function unstick() {
document.querySelectorAll('header, nav, [role="banner"], .header, .navbar, .sticky, .fixed-top, [style*="position: fixed"], [style*="position:sticky"]').forEach(function(el) {
if (el.style.position === 'fixed' || el.style.position === 'sticky' || getComputedStyle(el).position === 'fixed' || getComputedStyle(el).position === 'sticky') {
el.style.position = 'static';
el.style.top = 'auto';
el.style.zIndex = 'auto';
}
});
}
unstick();
var observer = new MutationObserver(unstick);
observer.observe(document.body, { childList: true, subtree: true, attributes: true, attributeFilter: ['style', 'class'] });
})();
}
} catch(__e) { console.warn('[Userscript:Kill Sticky Headers]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '
airflow-ctl 0.1.5: test to stable by bugraoz93 · Pull Request #67294 · apache/airflow · GitHub
Skip to content
airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

bugraoz93
merged 10 commits into

from

May 26, 2026
 Merged


airflow-ctl 0.1.5: test to stable
#67294
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


10 commits


Select commit
Hold shift + click to select a range
ef422ff

[airflow-ctl-v0-1-test] Allow remote version check without authentica…


bugraoz93 Apr 26, 2026
c22b090

[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…


bugraoz93 Apr 26, 2026
8c6bb32

[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …


bugraoz93 Apr 27, 2026
cb1426c

Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)


potiuk Apr 28, 2026
2e10497

[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …


choo121600 May 1, 2026
a781f73

[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…


bugraoz93 May 23, 2026
e65c3ec

[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…


bugraoz93 May 24, 2026
192441e

[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…


bugraoz93 May 24, 2026
871710c

Sync main to backport branch for airflowctl (#67559)


bugraoz93 May 26, 2026
f3bac6c

[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…


bugraoz93 May 26, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


4 changes: 4 additions & 0 deletions
.github/workflows/test-providers.yml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
 run: >
 breeze release-management prepare-task-sdk-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
 run: >
 breeze release-management prepare-airflow-ctl-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Verify ${{ matrix.package-format }} packages with twine"
 run: |
 uv tool uninstall twine || true
Expand Down

9 changes: 6 additions & 3 deletions
Dockerfile

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
 install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
 fi

 # Find Provider/TaskSDK/CTL distributions in docker-context files
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
 # Find Provider/TaskSDK/CTL distributions in docker-context files.
 # NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
 # ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
 # glob must say ``ctl``, not ``airflowctl``.
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
 echo
 echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
 echo
Expand Down

2 changes: 1 addition & 1 deletion
Dockerfile.ci

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down

29 changes: 18 additions & 11 deletions
airflow-core/pyproject.toml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
 "gitdb==4.0.12",
 "GitPython==3.1.46",
 "GitPython==3.1.50",
 "hatchling==1.29.0",
 "packaging==26.1",
 "pathspec==1.0.4",
 "packaging==26.2",
 "pathspec==1.1.1",
 "pluggy==1.6.0",
 "smmap==5.0.3",
 "tomli==2.4.1; python_version < '3.11'",
 "trove-classifiers==2026.1.14.14",
 "trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
 "a2wsgi>=1.10.8",
 "cachetools>=6.0.0",
 # aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
 # See https://github.com/omnilib/aiosqlite/issues/369
 # It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
 "dill>=0.2.2",
 "fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
 "uvicorn>=0.37.0",
 # Starlette 1.0.0 breaks the API server. Needs more investigation
 # https://github.com/apache/airflow/issues/64116
 "starlette>=0.45.0,<1",
 "starlette>=0.45.0",
 "httpx>=0.25.0",
 'importlib_metadata>=6.5;python_version<"3.12"',
 'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
 "tenacity>=8.3.0",
 "termcolor>=3.0.0",
 "typing-extensions>=4.14.1",
 # https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
 "universal-pathlib>=0.3.8",
 "uuid6>=2024.7.10",
 "apache-airflow-task-sdk==1.2.1",
 "apache-airflow-task-sdk<1.4.0,>=1.3.0",
 "apache-airflow-ctl<0.1.6,>=0.1.5",
 # pre-installed providers
 "apache-airflow-providers-common-compat>=1.7.4",
 "apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
 "apache-airflow-core[all]",
 "apache-airflow-ctl",
 "apache-airflow-devel-common",
 "apache-airflow-task-sdk",
 # TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
 # airflow-core tests
 "apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
 "apache-airflow-devel-common[docs]"
]
mypy = [
 "apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
 "apache-airflow-shared-secrets-backend",
 "apache-airflow-shared-secrets-masker",
 "apache-airflow-shared-serialization",
 "apache-airflow-shared-state",
 "apache-airflow-shared-timezones",
 "apache-airflow-shared-plugins-manager",
 "apache-airflow-shared-providers-discovery",
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
 """DAG schedule reference serializer for assets."""
 """Dag schedule reference serializer for assets."""

 dag_id: str
 created_at: datetime
Expand Down

14 changes: 7 additions & 7 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
 """Enum for DAG Run states when updating a DAG Run."""
 """Enum for Dag Run states when updating a Dag Run."""

 QUEUED = DagRunState.QUEUED
 SUCCESS = DagRunState.SUCCESS
 FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
 """DAG Run Serializer for PATCH requests."""
 """Dag Run Serializer for PATCH requests."""

 state: DAGRunPatchStates | None = None
 note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
 """DAG Run serializer for clear endpoint body."""
 """Dag Run serializer for clear endpoint body."""

 dry_run: bool = True
 only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
 """DAG Run serializer for responses."""
 """Dag Run serializer for responses."""

 dag_run_id: str = Field(validation_alias="run_id")
 dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
 """DAG Run Collection serializer for responses."""
 """Dag Run Collection serializer for responses."""

 dag_runs: Iterable[DAGRunResponse]
 total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
 """Trigger DAG Run Serializer for POST body."""
 """Trigger Dag Run Serializer for POST body."""

 dag_run_id: str | None = None
 data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
 """List DAG Runs body for batch endpoint."""
 """List Dag Runs body for batch endpoint."""

 order_by: str | None = None
 page_offset: NonNegativeInt = 0
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
 """DAG Source serializer for responses."""
 """Dag Source serializer for responses."""

 content: str | None
 dag_id: str
Expand Down

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
 """DAG Stats serializer for responses."""
 """Dag Stats serializer for responses."""

 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
 stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
 """DAG Stats Collection serializer for responses."""
 """Dag Stats Collection serializer for responses."""

 dags: list[DagStatsResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
 """DAG Tag serializer for responses."""
 """Dag Tag serializer for responses."""

 name: str
 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
 """DAG Tags Collection serializer for responses."""
 """Dag Tags Collection serializer for responses."""

 tags: list[str]
 total_entries: int

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
 """DAG Version Collection serializer for responses."""
 """Dag Version Collection serializer for responses."""

 dag_versions: Iterable[DagVersionResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
 """DAG Warning serializer for responses."""
 """Dag Warning serializer for responses."""

 dag_id: str
 warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
 """DAG warning collection serializer for responses."""
 """Dag warning collection serializer for responses."""

 dag_warnings: Iterable[DAGWarningResponse]
 total_entries: int

8 changes: 4 additions & 4 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
 """DAG serializer for responses."""
 """Dag serializer for responses."""

 model_config = ConfigDict(
 alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
 @field_validator("owners", mode="before")
 @classmethod
 def get_owners(cls, v: Any) -> list[str] | None:
 """Convert owners attribute to DAG representation."""
 """Convert owners attribute to Dag representation."""
 if not (v is None or isinstance(v, str)):
 return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
 """DAG Collection serializer for responses."""
 """Dag Collection serializer for responses."""

 dags: Iterable[DAGResponse]
 total_entries: int


class DAGDetailsResponse(DAGResponse):
 """Specific serializer for DAG Details responses."""
 """Specific serializer for Dag Details responses."""

 model_config = ConfigDict(
 from_attributes=True,
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
 - dag_id
 - dag_display_name
 title: DagTagResponse
 description: DAG Tag serializer for responses.
 description: Dag Tag serializer for responses.
 DagVersionResponse:
 properties:
 id:
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
// Universal Dark Mode - works on any site
(function() {
var enabled = true;
function applyDarkMode() {
if (!enabled) return;
// Create style element if it doesn't exist
var style = document.getElementById('universal-dark-mode-style');
if (!style) {
style = document.createElement('style');
style.id = 'universal-dark-mode-style';
document.head.appendChild(style);
}
// Dark mode CSS - inverts colors but preserves images/video
style.textContent = '
/* Invert everything except media */
html {
filter: invert(1) hue-rotate(180deg) !important;
background: #1a1a2e !important;
}
/* Restore images, videos, iframes, canvas */
img, video, iframe, canvas, svg, picture, [style*="background-image"] {
filter: invert(1) hue-rotate(180deg) !important;
}
/* Preserve specific elements that should not be inverted */
.no-dark-mode, .no-dark-mode *,
[data-theme="light"], [data-theme="light"],
.ace_editor, .ace_editor *,
.CodeMirror, .CodeMirror *,
.monaco-editor, .monaco-editor *,
.markdown-body pre, .markdown-body pre *,
.highlight, .highlight *,
pre code, pre code * {
filter: none !important;
}
/* Fix common UI elements */
.modal, .popup, .dropdown-menu, .tooltip, .popover {
filter: invert(1) hue-rotate(180deg) !important;
background: #2d2d44 !important;
border-color: #444 !important;
}
/* Scrollbars */
::-webkit-scrollbar { background: #1a1a2e !important; }
::-webkit-scrollbar-thumb { background: #444 !important; }
::-webkit-scrollbar-thumb:hover { background: #555 !important; }
/* Selection */
::selection { background: #4ecdc4 !important; color: #1a1a2e !important; }
::-moz-selection { background: #4ecdc4 !important; color: #1a1a2e !important; }
';
}
function removeDarkMode() {
var style = document.getElementById('universal-dark-mode-style');
if (style) style.remove();
}
// Toggle with Alt+Shift+D
document.addEventListener('keydown', function(e) {
if (e.altKey && e.shiftKey && e.key === 'D') {
e.preventDefault();
enabled = !enabled;
if (enabled) {
applyDarkMode();
console.log('[Universal Dark Mode] Enabled');
} else {
removeDarkMode();
console.log('[Universal Dark Mode] Disabled');
}
}
});
// Apply on load
applyDarkMode();
// Re-apply on dynamic content
var observer = new MutationObserver(function(mutations) {
if (enabled && !document.getElementById('universal-dark-mode-style')) {
applyDarkMode();
}
});
observer.observe(document.head, { childList: true });
console.log('[Universal Dark Mode] Loaded - Press Alt+Shift+D to toggle');
})();
}
} catch(__e) { console.warn('[Userscript:Universal Dark Mode]', __e); }
})();
})();
airflow-ctl 0.1.5: test to stable by bugraoz93 · Pull Request #67294 · apache/airflow · GitHub
Skip to content
airflow-ctl 0.1.5: test to stable#67294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

bugraoz93
merged 10 commits into

from

May 26, 2026
 Merged


airflow-ctl 0.1.5: test to stable
#67294
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


10 commits


Select commit
Hold shift + click to select a range
ef422ff

[airflow-ctl-v0-1-test] Allow remote version check without authentica…


bugraoz93 Apr 26, 2026
c22b090

[airflow-ctl-v0-1-test] use existing safe_load function in airflowctl…


bugraoz93 Apr 26, 2026
8c6bb32

[airflow-ctl-v0-1-test] airflowctl: Send backfill create and dry-run …


bugraoz93 Apr 27, 2026
cb1426c

Bump uv floor to 0.11.8, override cooldown for uv (#66042) (#66057)


potiuk Apr 28, 2026
2e10497

[airflow-ctl-v0-1-test] Align Dag capitalization from "DAG" to "Dag" …


choo121600 May 1, 2026
a781f73

[airflow-ctl/v0-1-test] Increment version of airflowctl for RC (#6729…


bugraoz93 May 23, 2026
e65c3ec

[airflow-ctl/v0-1-test] airflowctl: make required CLI params position…


bugraoz93 May 24, 2026
192441e

[airflow-ctl/v0-1-test] Add dags next execution command #66172 (#6618…


bugraoz93 May 24, 2026
871710c

Sync main to backport branch for airflowctl (#67559)


bugraoz93 May 26, 2026
f3bac6c

[airflow-ctl/v0-1-test] Add airflowctl 0.1.5 release notes (#67562) (…


bugraoz93 May 26, 2026

File filter

Filter by extension
Filter by extension
Conversations

Failed to load comments. 
Loading
Jump to

Jump to file


Failed to load files. 
Loading
 Diff view

 Diff view


4 changes: 4 additions & 0 deletions
.github/workflows/test-providers.yml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -128,6 +128,10 @@ jobs:
 run: >
 breeze release-management prepare-task-sdk-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Prepare airflow-ctl package: ${{ matrix.package-format }}"
 run: >
 breeze release-management prepare-airflow-ctl-distributions
 --distribution-format ${{ matrix.package-format }}
 - name: "Verify ${{ matrix.package-format }} packages with twine"
 run: |
 uv tool uninstall twine || true
Expand Down

9 changes: 6 additions & 3 deletions
Dockerfile

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -73,7 +73,7 @@ ARG PYTHON_LTO="true"
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_USE_UV="false"
ARG AIRFLOW_IMAGE_REPOSITORY="https://github.com/apache/airflow"
ARG AIRFLOW_IMAGE_README_URL="https://raw.githubusercontent.com/apache/airflow/main/docs/docker-stack/README.md"
Expand DownExpand Up@@ -1067,8 +1067,11 @@ function install_airflow_and_providers_from_docker_context_files(){
 install_airflow_core_distribution=("apache-airflow-core==${AIRFLOW_VERSION}")
 fi

 # Find Provider/TaskSDK/CTL distributions in docker-context files
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,airflowctl}*.{whl,tar.gz} 2>/dev/null || true)
 # Find Provider/TaskSDK/CTL distributions in docker-context files.
 # NOTE: the ctl wheel is named ``apache_airflow_ctl-*.whl`` (distribution
 # ``apache-airflow-ctl``), not ``apache_airflow_airflowctl-*.whl`` — the
 # glob must say ``ctl``, not ``airflowctl``.
 readarray -t airflow_distributions< <(python /scripts/docker/get_distribution_specs.py /docker-context-files/apache?airflow?{providers,task?sdk,ctl}*.{whl,tar.gz} 2>/dev/null || true)
 echo
 echo "${COLOR_BLUE}Found provider distributions in docker-context-files folder: ${airflow_distributions[*]}${COLOR_RESET}"
 echo
Expand Down

2 changes: 1 addition & 1 deletion
Dockerfile.ci

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -1828,7 +1828,7 @@ COPY --from=scripts common.sh install_packaging_tools.sh install_additional_depe
# Also use `force pip` label on your PR to swap all places we use `uv` to `pip`
ARG AIRFLOW_PIP_VERSION=26.0.1
# ARG AIRFLOW_PIP_VERSION="git+https://github.com/pypa/pip.git@main"
ARG AIRFLOW_UV_VERSION=0.11.7
ARG AIRFLOW_UV_VERSION=0.11.8
ARG AIRFLOW_PREK_VERSION="0.3.9"

# UV_LINK_MODE=copy is needed since we are using cache mounted from the host
Expand Down

29 changes: 18 additions & 11 deletions
airflow-core/pyproject.toml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -18,14 +18,14 @@
[build-system]
requires = [
 "gitdb==4.0.12",
 "GitPython==3.1.46",
 "GitPython==3.1.50",
 "hatchling==1.29.0",
 "packaging==26.1",
 "pathspec==1.0.4",
 "packaging==26.2",
 "pathspec==1.1.1",
 "pluggy==1.6.0",
 "smmap==5.0.3",
 "tomli==2.4.1; python_version < '3.11'",
 "trove-classifiers==2026.1.14.14",
 "trove-classifiers==2026.5.7.17",
]
build-backend = "hatchling.build"

Expand DownExpand Up@@ -64,10 +64,11 @@ classifiers = [
]

# Version is defined in src/airflow/__init__.py and it is automatically synchronized by prek hook
version = "3.2.1"
version = "3.3.0"

dependencies = [
 "a2wsgi>=1.10.8",
 "cachetools>=6.0.0",
 # aiosqlite 0.22.0 has a problem with hanging pytest sessions and we excluded it
 # See https://github.com/omnilib/aiosqlite/issues/369
 # It seems that while our test issues are fixed in 0.22.1, sqlalchemy 2 itself
Expand DownExpand Up@@ -96,9 +97,7 @@ dependencies = [
 "dill>=0.2.2",
 "fastapi[standard-no-fastapi-cloud-cli]>=0.129.0",
 "uvicorn>=0.37.0",
 # Starlette 1.0.0 breaks the API server. Needs more investigation
 # https://github.com/apache/airflow/issues/64116
 "starlette>=0.45.0,<1",
 "starlette>=0.45.0",
 "httpx>=0.25.0",
 'importlib_metadata>=6.5;python_version<"3.12"',
 'importlib_metadata>=7.0;python_version>="3.12"',
Expand DownExpand Up@@ -148,10 +147,10 @@ dependencies = [
 "tenacity>=8.3.0",
 "termcolor>=3.0.0",
 "typing-extensions>=4.14.1",
 # https://github.com/apache/airflow/issues/56369 , rework universal-pathlib usage
 "universal-pathlib>=0.3.8",
 "uuid6>=2024.7.10",
 "apache-airflow-task-sdk==1.2.1",
 "apache-airflow-task-sdk<1.4.0,>=1.3.0",
 "apache-airflow-ctl<0.1.6,>=0.1.5",
 # pre-installed providers
 "apache-airflow-providers-common-compat>=1.7.4",
 "apache-airflow-providers-common-io>=1.6.3",
Expand DownExpand Up@@ -249,6 +248,7 @@ exclude = [
"../shared/secrets_backend/src/airflow_shared/secrets_backend" = "src/airflow/_shared/secrets_backend"
"../shared/secrets_masker/src/airflow_shared/secrets_masker" = "src/airflow/_shared/secrets_masker"
"../shared/serialization/src/airflow_shared/serialization" = "src/airflow/_shared/serialization"
"../shared/state/src/airflow_shared/state" = "src/airflow/_shared/state"
"../shared/timezones/src/airflow_shared/timezones" = "src/airflow/_shared/timezones"
"../shared/listeners/src/airflow_shared/listeners" = "src/airflow/_shared/listeners"
"../shared/plugins_manager/src/airflow_shared/plugins_manager" = "src/airflow/_shared/plugins_manager"
Expand DownExpand Up@@ -285,6 +285,7 @@ dev = [
 "apache-airflow-core[all]",
 "apache-airflow-ctl",
 "apache-airflow-devel-common",
 "apache-airflow-task-sdk",
 # TODO(potiuk): eventually we do not want any providers nor apache-airflow extras to be needed for
 # airflow-core tests
 "apache-airflow[pandas,polars]",
Expand All@@ -311,13 +312,18 @@ dev = [
docs = [
 "apache-airflow-devel-common[docs]"
]
mypy = [
 "apache-airflow-devel-common[mypy]",
]



[tool.uv]
required-version = ">=0.6.3"
required-version = ">=0.11.8"

[tool.uv.sources]
apache-airflow-core = {workspace = true}
apache-airflow-ctl = {workspace = true}
apache-airflow-devel-common = { workspace = true }

[tool.airflow]
Expand All@@ -331,6 +337,7 @@ shared_distributions = [
 "apache-airflow-shared-secrets-backend",
 "apache-airflow-shared-secrets-masker",
 "apache-airflow-shared-serialization",
 "apache-airflow-shared-state",
 "apache-airflow-shared-timezones",
 "apache-airflow-shared-plugins-manager",
 "apache-airflow-shared-providers-discovery",
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/assets.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -34,7 +34,7 @@


class DagScheduleAssetReference(StrictBaseModel):
 """DAG schedule reference serializer for assets."""
 """Dag schedule reference serializer for assets."""

 dag_id: str
 created_at: datetime
Expand Down

14 changes: 7 additions & 7 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -36,22 +36,22 @@


class DAGRunPatchStates(str, Enum):
 """Enum for DAG Run states when updating a DAG Run."""
 """Enum for Dag Run states when updating a Dag Run."""

 QUEUED = DagRunState.QUEUED
 SUCCESS = DagRunState.SUCCESS
 FAILED = DagRunState.FAILED


class DAGRunPatchBody(StrictBaseModel):
 """DAG Run Serializer for PATCH requests."""
 """Dag Run Serializer for PATCH requests."""

 state: DAGRunPatchStates | None = None
 note: str | None = Field(None, max_length=1000)


class DAGRunClearBody(StrictBaseModel):
 """DAG Run serializer for clear endpoint body."""
 """Dag Run serializer for clear endpoint body."""

 dry_run: bool = True
 only_failed: bool = False
Expand All@@ -62,7 +62,7 @@ class DAGRunClearBody(StrictBaseModel):


class DAGRunResponse(BaseModel):
 """DAG Run serializer for responses."""
 """Dag Run serializer for responses."""

 dag_run_id: str = Field(validation_alias="run_id")
 dag_id: str
Expand All@@ -88,14 +88,14 @@ class DAGRunResponse(BaseModel):


class DAGRunCollectionResponse(BaseModel):
 """DAG Run Collection serializer for responses."""
 """Dag Run Collection serializer for responses."""

 dag_runs: Iterable[DAGRunResponse]
 total_entries: int


class TriggerDAGRunPostBody(StrictBaseModel):
 """Trigger DAG Run Serializer for POST body."""
 """Trigger Dag Run Serializer for POST body."""

 dag_run_id: str | None = None
 data_interval_start: AwareDatetime | None = None
Expand DownExpand Up@@ -145,7 +145,7 @@ def validate_context(self, dag: SerializedDAG) -> dict:


class DAGRunsBatchBody(StrictBaseModel):
 """List DAG Runs body for batch endpoint."""
 """List Dag Runs body for batch endpoint."""

 order_by: str | None = None
 page_offset: NonNegativeInt = 0
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -22,7 +22,7 @@


class DAGSourceResponse(BaseModel):
 """DAG Source serializer for responses."""
 """Dag Source serializer for responses."""

 content: str | None
 dag_id: str
Expand Down

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_stats.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -31,15 +31,15 @@ class DagStatsStateResponse(BaseModel):


class DagStatsResponse(BaseModel):
 """DAG Stats serializer for responses."""
 """Dag Stats serializer for responses."""

 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag_model", "dag_display_name"))
 stats: list[DagStatsStateResponse]


class DagStatsCollectionResponse(BaseModel):
 """DAG Stats Collection serializer for responses."""
 """Dag Stats Collection serializer for responses."""

 dags: list[DagStatsResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_tags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -23,15 +23,15 @@


class DagTagResponse(BaseModel):
 """DAG Tag serializer for responses."""
 """Dag Tag serializer for responses."""

 name: str
 dag_id: str
 dag_display_name: str = Field(validation_alias=AliasPath("dag", "dag_display_name"))


class DAGTagCollectionResponse(BaseModel):
 """DAG Tags Collection serializer for responses."""
 """Dag Tags Collection serializer for responses."""

 tags: list[str]
 total_entries: int

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_versions.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -40,7 +40,7 @@ class DagVersionResponse(BaseModel):


class DAGVersionCollectionResponse(BaseModel):
 """DAG Version Collection serializer for responses."""
 """Dag Version Collection serializer for responses."""

 dag_versions: Iterable[DagVersionResponse]
 total_entries: int

4 changes: 2 additions & 2 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_warning.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -27,7 +27,7 @@


class DAGWarningResponse(BaseModel):
 """DAG Warning serializer for responses."""
 """Dag Warning serializer for responses."""

 dag_id: str
 warning_type: DagWarningType
Expand All@@ -37,7 +37,7 @@ class DAGWarningResponse(BaseModel):


class DAGWarningCollectionResponse(BaseModel):
 """DAG warning collection serializer for responses."""
 """Dag warning collection serializer for responses."""

 dag_warnings: Iterable[DAGWarningResponse]
 total_entries: int

8 changes: 4 additions & 4 deletions
airflow-core/src/airflow/api_fastapi/core_api/datamodels/dags.py

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -66,7 +66,7 @@ def _get_file_token_serializer() -> URLSafeSerializer:


class DAGResponse(BaseModel):
 """DAG serializer for responses."""
 """Dag serializer for responses."""

 model_config = ConfigDict(
 alias_generator=AliasGenerator(
Expand DownExpand Up@@ -110,7 +110,7 @@ def serialize_tags(self, tags: list[DagTagResponse]) -> list[DagTagResponse]:
 @field_validator("owners", mode="before")
 @classmethod
 def get_owners(cls, v: Any) -> list[str] | None:
 """Convert owners attribute to DAG representation."""
 """Convert owners attribute to Dag representation."""
 if not (v is None or isinstance(v, str)):
 return v

Expand DownExpand Up@@ -150,14 +150,14 @@ class DAGPatchBody(StrictBaseModel):


class DAGCollectionResponse(BaseModel):
 """DAG Collection serializer for responses."""
 """Dag Collection serializer for responses."""

 dags: Iterable[DAGResponse]
 total_entries: int


class DAGDetailsResponse(DAGResponse):
 """Specific serializer for DAG Details responses."""
 """Specific serializer for Dag Details responses."""

 model_config = ConfigDict(
 from_attributes=True,
Expand Down

2 changes: 1 addition & 1 deletion
airflow-core/src/airflow/api_fastapi/core_api/openapi/_private_ui.yaml

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -2052,7 +2052,7 @@ components:
 - dag_id
 - dag_display_name
 title: DagTagResponse
 description: DAG Tag serializer for responses.
 description: Dag Tag serializer for responses.
 DagVersionResponse:
 properties:
 id:
Expand Down
Loading