From 241a5029819f6ea4d489a2adffc58c8eea0e1043 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Fri, 21 Nov 2025 13:19:52 +0000 Subject: [PATCH 01/11] Bump version to 1.12.0a3 and update changelog --- CHANGELOG.rst | 36 ++++++++++++++++++++++++++++++------ cosmos/__init__.py | 2 +- 2 files changed, 31 insertions(+), 7 deletions(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index e6c66e0edd..b0607d92f8 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -1,8 +1,8 @@ Changelog ========= -1.12.0a2 (2025-11-12) -------------------- +1.12.0a3 (2025-11-21) +---------------------- Breaking changes @@ -10,18 +10,42 @@ Breaking changes - ``generate_task_or_group`` receives ``render_config`` instead of its individual configurations, such as ``test_behavior``, ``source_rendering_behavior`` and ``enable_owner_inheritance`` - ``create_task_metadata`` receives ``render_config`` instead of its individual configurations, such as ``test_behavior``, ``source_rendering_behavior`` and ``enable_owner_inheritance`` - ``create_task_metadata`` now expects the ``node_converters`` argument -* Drop Python 3.9 Support by @pankajastro in #2118 +* Drop Python 3.9 support by @pankajastro in #2118 Features * Support applying ``node_converter`` at a task level instead of task group level by @anyapriya in #1759 +* Allow overriding ``DbtProducerWatcherOperator`` parameters via ``ExecutionConfig.setup_operator_args`` by @pankajastro in #2133 +* Use deferrable sensors by default in ``ExecutionMode.WATCHER`` by @pankajastro in #2084 Enhancements -* By default, use deferrable sensors when using ``ExecutionMode.WATCHER`` by @pankajastro in #2084 -* Unify airflow version handling into ``constants.py`` by @tatiana in #2089 -* Refactor ``airflow/graph.py`` to simplify code-base by @tatiana in #2080 +* Unify Airflow version handling into ``constants.py`` by @tatiana in #2089 +* Refactor ``airflow/graph.py`` to simplify the code base by @tatiana in #2080 +* Force watcher producer retries to zero by @pankajkoti in #2114 +* Fail ``ExecutionMode.WATCHER`` consumer sensors immediately when the producer fails using Airflow context by @pankajkoti in #2126 + +Bug fixes + +* Clarify watcher deferrable failure messaging by @pankajkoti in #2124 +* Remove empty test tasks when all tests are detached by @anyapriya in #2010 +* Fix forwarding DbtProducerWatcherOperator dbt build flags by @michal-mrazek in #2127 + +Docs + +* Document dataset-event limitation when using ``ExecutionMode.AIRFLOW_ASYNC`` by @varaprasadregani in #2143 +* Expand ``ExecutionMode.KUBERNETES`` guidance by @pankajastro in #2139 +* Add docs for deferrable ``DbtConsumerWatcherSensor`` by @pankajastro in #2115 +* Fix reStructuredText formatting by @dnskr in #2132 + +Others +* Retry flaky telemetry success test to stabilise CI by @pankajkoti in #2138 +* Remove unused Python3.9 uses from Github action CI by @pankajastro in #2117 +* Drop Python 3.9 support by @pankajastro in #2118 +* Bump actions/checkout from 5.0.0 to 5.0.1 by @dependabot in #2135 +* pre-commit autoupdate by @pre-commit-ci[bot] in #2134 +* Bump ``actions/checkout`` to 6.0.0 in GitHub workflows by @dependabot in #2147 1.11.1 (2025-11-12) -------------------- diff --git a/cosmos/__init__.py b/cosmos/__init__.py index 4e62b386bd..00ca576392 100644 --- a/cosmos/__init__.py +++ b/cosmos/__init__.py @@ -9,7 +9,7 @@ from cosmos import settings -__version__ = "1.12.0a2" +__version__ = "1.12.0a3" if not settings.enable_memory_optimised_imports: from cosmos.airflow.dag import DbtDag From d645d3f255055db6945f743ad88146d9e2ac80c1 Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Fri, 21 Nov 2025 13:30:04 +0000 Subject: [PATCH 02/11] =?UTF-8?q?=F0=9F=8E=A8=20[pre-commit.ci]=20Auto=20f?= =?UTF-8?q?ormat=20from=20pre-commit.com=20hooks?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cosmos/operators/watcher.py | 1 - 1 file changed, 1 deletion(-) diff --git a/cosmos/operators/watcher.py b/cosmos/operators/watcher.py index 139d11064b..8d103687f4 100644 --- a/cosmos/operators/watcher.py +++ b/cosmos/operators/watcher.py @@ -30,7 +30,6 @@ except ImportError: # pragma: no cover from airflow.operators.empty import EmptyOperator # type: ignore[no-redef] -from packaging.version import Version from cosmos._utils.watcher_state import build_producer_state_fetcher from cosmos.config import ProfileConfig From bfbce0045c01543450ef8301ed85d6e718124d92 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Fri, 21 Nov 2025 13:46:42 +0000 Subject: [PATCH 03/11] Update changelog with additional 1.12.0a3 entries --- CHANGELOG.rst | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index b0607d92f8..09476d52e7 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -24,12 +24,13 @@ Enhancements * Refactor ``airflow/graph.py`` to simplify the code base by @tatiana in #2080 * Force watcher producer retries to zero by @pankajkoti in #2114 * Fail ``ExecutionMode.WATCHER`` consumer sensors immediately when the producer fails using Airflow context by @pankajkoti in #2126 +* ``ExecutonMode.Watcher``: fetch producer status asynchronously from the Airflow runtime so deferrable sensors fail immediately when the producer task fails by @pankajkoti in #2144 Bug fixes * Clarify watcher deferrable failure messaging by @pankajkoti in #2124 * Remove empty test tasks when all tests are detached by @anyapriya in #2010 -* Fix forwarding DbtProducerWatcherOperator dbt build flags by @michal-mrazek in #2127 +* Fix forwarding ``DbtProducerWatcherOperator`` ``dbt build`` flags by @michal-mrazek in #2127 Docs @@ -40,12 +41,14 @@ Docs Others -* Retry flaky telemetry success test to stabilise CI by @pankajkoti in #2138 -* Remove unused Python3.9 uses from Github action CI by @pankajastro in #2117 +* Retry flaky Telemetry success test to stabilise CI by @pankajkoti in #2138 +* Drop unused producer state xcom handling in ``ExecutionMode.WATCHER`` by @pankajkoti in #2145 * Drop Python 3.9 support by @pankajastro in #2118 -* Bump actions/checkout from 5.0.0 to 5.0.1 by @dependabot in #2135 +* Remove unused Python3.9 uses from Github action CI by @pankajastro in #2117 +* Bump ``actions/checkout`` from ``5.0.0`` to ``5.0.1`` by @dependabot in #2135 +* Bump ``actions/checkout`` to ``6.0.0`` in GitHub workflows by @dependabot in #2147 * pre-commit autoupdate by @pre-commit-ci[bot] in #2134 -* Bump ``actions/checkout`` to 6.0.0 in GitHub workflows by @dependabot in #2147 + 1.11.1 (2025-11-12) -------------------- From 85365af37af1450e84215812c2cf53f6ac62e600 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Mon, 24 Nov 2025 16:19:52 +0530 Subject: [PATCH 04/11] Apply suggestion from @tatiana Co-authored-by: Tatiana Al-Chueyr --- CHANGELOG.rst | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 09476d52e7..212ba8f7de 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -35,7 +35,7 @@ Bug fixes Docs * Document dataset-event limitation when using ``ExecutionMode.AIRFLOW_ASYNC`` by @varaprasadregani in #2143 -* Expand ``ExecutionMode.KUBERNETES`` guidance by @pankajastro in #2139 +* Expand ``ExecutionMode.KUBERNETES`` guidance by @tatiana in #2139 * Add docs for deferrable ``DbtConsumerWatcherSensor`` by @pankajastro in #2115 * Fix reStructuredText formatting by @dnskr in #2132 From 2f5fff09161762a080129c44a04fbd0d897287da Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Tue, 9 Dec 2025 21:29:19 +0530 Subject: [PATCH 05/11] Update Changelog and bump alpha version --- CHANGELOG.rst | 38 +++++++++++++++++++++++++++++++++----- cosmos/__init__.py | 2 +- 2 files changed, 34 insertions(+), 6 deletions(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 212ba8f7de..ee064e80ee 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -1,7 +1,7 @@ Changelog ========= -1.12.0a3 (2025-11-21) +1.12.0a4 (2025-12-09) ---------------------- Breaking changes @@ -11,12 +11,15 @@ Breaking changes - ``create_task_metadata`` receives ``render_config`` instead of its individual configurations, such as ``test_behavior``, ``source_rendering_behavior`` and ``enable_owner_inheritance`` - ``create_task_metadata`` now expects the ``node_converters`` argument * Drop Python 3.9 support by @pankajastro in #2118 +* Drop Airflow 2.4 support by @pankajastro in #2161 +* Drop Airflow 2.5 support by @pankajastro in #2165 Features * Support applying ``node_converter`` at a task level instead of task group level by @anyapriya in #1759 * Allow overriding ``DbtProducerWatcherOperator`` parameters via ``ExecutionConfig.setup_operator_args`` by @pankajastro in #2133 * Use deferrable sensors by default in ``ExecutionMode.WATCHER`` by @pankajastro in #2084 +* Support real-time consumer updates when using ``ExecutionMode.WATCHER`` and ``InvocationMode.SUBPROCESS`` by @pankajastro in #2152 Enhancements @@ -24,13 +27,16 @@ Enhancements * Refactor ``airflow/graph.py`` to simplify the code base by @tatiana in #2080 * Force watcher producer retries to zero by @pankajkoti in #2114 * Fail ``ExecutionMode.WATCHER`` consumer sensors immediately when the producer fails using Airflow context by @pankajkoti in #2126 -* ``ExecutonMode.Watcher``: fetch producer status asynchronously from the Airflow runtime so deferrable sensors fail immediately when the producer task fails by @pankajkoti in #2144 +* ``ExecutonMode.WATCHER``: fetch producer status asynchronously from the Airflow runtime so deferrable sensors fail immediately when the producer task fails by @pankajkoti in #2144 +* Refactor ``ExecutionMode.WATCHER`` ``InvocationMode.SUBPROCESS`` log parser by @tatiana in #2183 Bug fixes -* Clarify watcher deferrable failure messaging by @pankajkoti in #2124 +* Clarify ``ExecutionMode.WATCHER`` deferrable failure messaging by @pankajkoti in #2124 * Remove empty test tasks when all tests are detached by @anyapriya in #2010 * Fix forwarding ``DbtProducerWatcherOperator`` ``dbt build`` flags by @michal-mrazek in #2127 +* Add databricks oauth mock profile by @fjmacagno in #2164 +* Register listeners in Airflow 3 plugin implementation by @pankajastro in #2187 Docs @@ -38,16 +44,38 @@ Docs * Expand ``ExecutionMode.KUBERNETES`` guidance by @tatiana in #2139 * Add docs for deferrable ``DbtConsumerWatcherSensor`` by @pankajastro in #2115 * Fix reStructuredText formatting by @dnskr in #2132 +* Add docs for ``setup_operator_args`` param by @pankajastro in #2136 +* Remove experimental flag for ``ExecutionMode.AIRFLOW_ASYNC`` by @pankajastro in #2153 +* Clarify ``ExecutionMode.AIRFLOW_ASYNC`` dataset limits by @pankajkoti in #2167 Others +* Drop Python 3.9 support by @pankajastro in #2118 +* Drop Airflow 2.4 support by @pankajastro in #2161 +* Drop Airflow 2.5 support by @pankajastro in #2165 +* Improve example DAG ``jaffle_shop_kubernetes.py`` by @tatiana in #2140 +* Enable tests for Python 3.13 by @pankajastro in #2154 +* Add Python 3.12 to CI integration tests matrix by @pankajastro in #2168 * Retry flaky Telemetry success test to stabilise CI by @pankajkoti in #2138 * Drop unused producer state xcom handling in ``ExecutionMode.WATCHER`` by @pankajkoti in #2145 -* Drop Python 3.9 support by @pankajastro in #2118 * Remove unused Python3.9 uses from Github action CI by @pankajastro in #2117 +* Run pre-commit on ``ExecutionMode.WATCHER`` modules by @pankajkoti in #2150 +* Refactor: Use shared airflow version constant by @pankajkoti in #2157 +* Pin ``pydantic<2.0`` for Airflow 2.6 compatibility by @pankajastro in #2172 +* Remove duplicate ``dbt-duckdb`` dependency by @pankajastro in #2170 +* Add targeted ``type: ignore`` for untyped decorators to fix ``mypy`` errors by @pankajastro in #2174 +* Replace Legacy typing Aliases with Built-in Types for Python 3.10+ by @pankajastro in #2175 +* Refactor to reuse ``load_method_from_module`` from ``_utils/importer.py`` by @pankajastro in #2176 +* Remove try except block for cache import and unused python_version variable by @pankajastro in #2186 +* Unpin Airflow to satisfy GitHub Security tab requirements by @pankajastro in #2171 +* Update Python version for ``pyupgrade`` in ``pre-commit`` config by @pankajastro in #2190 +* Add cooldown config in ``dependabot`` config by @pankajastro in #2189 * Bump ``actions/checkout`` from ``5.0.0`` to ``5.0.1`` by @dependabot in #2135 * Bump ``actions/checkout`` to ``6.0.0`` in GitHub workflows by @dependabot in #2147 -* pre-commit autoupdate by @pre-commit-ci[bot] in #2134 +* Bump ``zizmorcore/zizmor-action`` from ``0.2.0`` to ``0.3.0`` by @dependabot in #2156 +* Bump ``actions/checkout`` from ``5.0.1`` to ``6.0.0`` by @dependabot in #2155 +* Bump ``actions/checkout`` from ``6.0.0`` to ``6.0.1`` by @dependabot in #2178 +* pre-commit autoupdate by @pre-commit-ci[bot] in #2134, #2162, #2173, #2191 1.11.1 (2025-11-12) diff --git a/cosmos/__init__.py b/cosmos/__init__.py index 00ca576392..01c2adeffd 100644 --- a/cosmos/__init__.py +++ b/cosmos/__init__.py @@ -9,7 +9,7 @@ from cosmos import settings -__version__ = "1.12.0a3" +__version__ = "1.12.0a4" if not settings.enable_memory_optimised_imports: from cosmos.airflow.dag import DbtDag From 02344a80ccba3dbd24cfb09734d033ce02a24542 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Thu, 18 Dec 2025 20:35:23 +0530 Subject: [PATCH 06/11] Update Changelog and bump alpha version --- CHANGELOG.rst | 14 ++++++++++++-- cosmos/__init__.py | 2 +- 2 files changed, 13 insertions(+), 3 deletions(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 53f9a7831c..fa125016e7 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -1,7 +1,7 @@ Changelog ========= -1.12.0a4 (2025-12-09) +1.12.0a5 (2025-12-18) ---------------------- Breaking changes @@ -20,6 +20,8 @@ Features * Allow overriding ``DbtProducerWatcherOperator`` parameters via ``ExecutionConfig.setup_operator_args`` by @pankajastro in #2133 * Use deferrable sensors by default in ``ExecutionMode.WATCHER`` by @pankajastro in #2084 * Support real-time consumer updates when using ``ExecutionMode.WATCHER`` and ``InvocationMode.SUBPROCESS`` by @pankajastro in #2152 +* Update telemetry to v3 format with query parameters by @pankajkoti in #2192 +* Add initial set of telemetry task listener metrics for Cosmos operators by @pankajkoti in #2195 Enhancements @@ -29,6 +31,7 @@ Enhancements * Fail ``ExecutionMode.WATCHER`` consumer sensors immediately when the producer fails using Airflow context by @pankajkoti in #2126 * ``ExecutonMode.WATCHER``: fetch producer status asynchronously from the Airflow runtime so deferrable sensors fail immediately when the producer task fails by @pankajkoti in #2144 * Refactor ``ExecutionMode.WATCHER`` ``InvocationMode.SUBPROCESS`` log parser by @tatiana in #2183 +* Replace map_index with is_mapped_task boolean in task telemetry metrics by @pankajkoti in #2210 Bug fixes @@ -37,6 +40,9 @@ Bug fixes * Fix forwarding ``DbtProducerWatcherOperator`` ``dbt build`` flags by @michal-mrazek in #2127 * Add databricks oauth mock profile by @fjmacagno in #2164 * Register listeners in Airflow 3 plugin implementation by @pankajastro in #2187 +* Fix resolution of ``packages-install-path`` when it uses ``env_var`` by @tatiana in #2194 +* Fix ``template_fields`` in ``DbtConsumerWatcherSensor`` to include ``DbtRunLocalOperator`` template_fields`` by @tiovader and @emanuel-luis in #2209 +* Emit asset events in ExecutionMode.AIRFLOW_ASYNC mode by @pankajastro in #2184 Docs @@ -70,12 +76,16 @@ Others * Unpin Airflow to satisfy GitHub Security tab requirements by @pankajastro in #2171 * Update Python version for ``pyupgrade`` in ``pre-commit`` config by @pankajastro in #2190 * Add cooldown config in ``dependabot`` config by @pankajastro in #2189 +* Adjust pre-commit so Python 3.10 or higher can be used by @tatiana in #2196 +* Remove empty variables emission from telemetry metrics by @pankajkoti in #2197 +* Reformat documented comments for historical URL formats by @pankajkoti in #2199 * Bump ``actions/checkout`` from ``5.0.0`` to ``5.0.1`` by @dependabot in #2135 * Bump ``actions/checkout`` to ``6.0.0`` in GitHub workflows by @dependabot in #2147 * Bump ``zizmorcore/zizmor-action`` from ``0.2.0`` to ``0.3.0`` by @dependabot in #2156 * Bump ``actions/checkout`` from ``5.0.1`` to ``6.0.0`` by @dependabot in #2155 * Bump ``actions/checkout`` from ``6.0.0`` to ``6.0.1`` by @dependabot in #2178 -* pre-commit autoupdate by @pre-commit-ci[bot] in #2134, #2162, #2173, #2191 +* Bump ``codecov/codecov-action`` from ``5.5.1`` to ``5.5.2`` by @dependabot in #2208 +* pre-commit autoupdate by @pre-commit-ci[bot] in #2134, #2162, #2173, #2191, #2202 1.11.2 (2025-11-24) -------------------- diff --git a/cosmos/__init__.py b/cosmos/__init__.py index 01c2adeffd..9d61d8a5ae 100644 --- a/cosmos/__init__.py +++ b/cosmos/__init__.py @@ -9,7 +9,7 @@ from cosmos import settings -__version__ = "1.12.0a4" +__version__ = "1.12.0a5" if not settings.enable_memory_optimised_imports: from cosmos.airflow.dag import DbtDag From 40d2ffc87af3c772152917830f0e6e0ea13c6122 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Thu, 18 Dec 2025 20:55:46 +0530 Subject: [PATCH 07/11] Update Changelog --- CHANGELOG.rst | 3 +++ 1 file changed, 3 insertions(+) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 49a0542d0e..30390be298 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -32,6 +32,8 @@ Enhancements * ``ExecutonMode.WATCHER``: fetch producer status asynchronously from the Airflow runtime so deferrable sensors fail immediately when the producer task fails by @pankajkoti in #2144 * Refactor ``ExecutionMode.WATCHER`` ``InvocationMode.SUBPROCESS`` log parser by @tatiana in #2183 * Replace map_index with is_mapped_task boolean in task telemetry metrics by @pankajkoti in #2210 +* Collect cosmos profile metrics in task telemetry metrics by @pankajastro in #2198 +* Remove unnecessary information from telemetry by @tatiana in #2211 Bug fixes @@ -53,6 +55,7 @@ Docs * Add docs for ``setup_operator_args`` param by @pankajastro in #2136 * Remove experimental flag for ``ExecutionMode.AIRFLOW_ASYNC`` by @pankajastro in #2153 * Clarify ``ExecutionMode.AIRFLOW_ASYNC`` dataset limits by @pankajkoti in #2167 +* Update PRIVACY_NOTICE.rst by @tatiana in #2212 Others From 30e8b232f401e4f4df1099aace3c3009b8385034 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Thu, 18 Dec 2025 21:01:58 +0530 Subject: [PATCH 08/11] Update Changelog --- CHANGELOG.rst | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 30390be298..4a4e90b25b 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -45,6 +45,7 @@ Bug fixes * Fix resolution of ``packages-install-path`` when it uses ``env_var`` by @tatiana in #2194 * Fix ``template_fields`` in ``DbtConsumerWatcherSensor`` to include ``DbtRunLocalOperator`` template_fields`` by @tiovader and @emanuel-luis in #2209 * Emit asset events in ExecutionMode.AIRFLOW_ASYNC mode by @pankajastro in #2184 +* Remove dag_run_id from telemetry tests by @tatiana in #2213 Docs From 96e1f7016fee56f8b8f7b08c4af67a4e7a78943c Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Thu, 18 Dec 2025 21:03:40 +0530 Subject: [PATCH 09/11] Update cosmos/__init__.py --- cosmos/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cosmos/__init__.py b/cosmos/__init__.py index 9d61d8a5ae..d113ba240b 100644 --- a/cosmos/__init__.py +++ b/cosmos/__init__.py @@ -9,7 +9,7 @@ from cosmos import settings -__version__ = "1.12.0a5" +__version__ = "1.12.0" if not settings.enable_memory_optimised_imports: from cosmos.airflow.dag import DbtDag From 97871b8169df46d16ffd780647f7ac67645696f7 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Thu, 18 Dec 2025 21:03:48 +0530 Subject: [PATCH 10/11] Update CHANGELOG.rst --- CHANGELOG.rst | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 4a4e90b25b..18824b4fc7 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -1,7 +1,7 @@ Changelog ========= -1.12.0a5 (2025-12-18) +1.12.0 (2025-12-18) ---------------------- Breaking changes From ad5489175b32998b5eb013739d7a63ab70cebad2 Mon Sep 17 00:00:00 2001 From: Pankaj Koti Date: Thu, 18 Dec 2025 21:17:01 +0530 Subject: [PATCH 11/11] Update CHANGELOG.rst Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --- CHANGELOG.rst | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 18824b4fc7..f71af2abd9 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -29,7 +29,7 @@ Enhancements * Refactor ``airflow/graph.py`` to simplify the code base by @tatiana in #2080 * Force watcher producer retries to zero by @pankajkoti in #2114 * Fail ``ExecutionMode.WATCHER`` consumer sensors immediately when the producer fails using Airflow context by @pankajkoti in #2126 -* ``ExecutonMode.WATCHER``: fetch producer status asynchronously from the Airflow runtime so deferrable sensors fail immediately when the producer task fails by @pankajkoti in #2144 +* ``ExecutionMode.WATCHER``: fetch producer status asynchronously from the Airflow runtime so deferrable sensors fail immediately when the producer task fails by @pankajkoti in #2144 * Refactor ``ExecutionMode.WATCHER`` ``InvocationMode.SUBPROCESS`` log parser by @tatiana in #2183 * Replace map_index with is_mapped_task boolean in task telemetry metrics by @pankajkoti in #2210 * Collect cosmos profile metrics in task telemetry metrics by @pankajastro in #2198