This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 46ff76ec9c2 Fix the @asset example in the asset state store docs
(#75070)
46ff76ec9c2 is described below
commit 46ff76ec9c20f054fe318ef6442c1be846ec10be
Author: W. H. Wang <[email protected]>
AuthorDate: Mon Oct 19 22:44:09 2026 +0800
Fix the @asset example in the asset state store docs (#75070)
The example could not be imported: @asset requires a schedule argument, and
it rejects **kwargs because it derives inlet assets from parameter names.
Readers copying it got a TypeError instead of a working asset.
---
airflow-core/docs/core-concepts/asset-state-store.rst | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow-core/docs/core-concepts/asset-state-store.rst
b/airflow-core/docs/core-concepts/asset-state-store.rst
index ddb3fe93fb4..9e888d6e558 100644
--- a/airflow-core/docs/core-concepts/asset-state-store.rst
+++ b/airflow-core/docs/core-concepts/asset-state-store.rst
@@ -50,8 +50,8 @@ This applies to both the ``@asset`` pattern and the ``@task``
pattern:
# @asset Dags implicitly declare the asset as an outlet
- @asset
- def my_asset_dag(**context):
+ @asset(schedule=None)
+ def my_asset_dag(context):
context["asset_state_store"].set("watermark", "2024-06-01")