This is an automated email from the ASF dual-hosted git repository.
kaxil 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 224d34121c8 Fix wrong session type in state-store custom-backend doc
example (#73361)
224d34121c8 is described below
commit 224d34121c877c21e8dee97520b05c02f578a839
Author: Kaxil Naik <[email protected]>
AuthorDate: Sat Sep 19 08:19:52 2026 +0100
Fix wrong session type in state-store custom-backend doc example (#73361)
---
.../administration-and-deployment/task-and-asset-state-store.rst | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/airflow-core/docs/administration-and-deployment/task-and-asset-state-store.rst
b/airflow-core/docs/administration-and-deployment/task-and-asset-state-store.rst
index 706d5576679..b2384e6b8dd 100644
---
a/airflow-core/docs/administration-and-deployment/task-and-asset-state-store.rst
+++
b/airflow-core/docs/administration-and-deployment/task-and-asset-state-store.rst
@@ -150,13 +150,13 @@ If the storage client is synchronous, implement the async
methods by offloading
return await asyncio.to_thread(self.get, scope, key)
async def aset(self, scope, key, value, *, expires_at=None,
session=None):
- await asyncio.to_thread(self.set, scope, key, value,
expires_at=expires_at, session=session)
+ await asyncio.to_thread(self.set, scope, key, value,
expires_at=expires_at)
async def adelete(self, scope, key, *, session=None):
- await asyncio.to_thread(self.delete, scope, key, session=session)
+ await asyncio.to_thread(self.delete, scope, key)
async def aclear(self, scope, *, all_map_indices=False, session=None):
- await asyncio.to_thread(self.clear, scope,
all_map_indices=all_map_indices, session=session)
+ await asyncio.to_thread(self.clear, scope,
all_map_indices=all_map_indices)
:class:`~airflow.sdk.state.AssetScope` has three optional fields: ``asset_id``
(integer, server-side only), ``name``, and ``uri``. At least one must be set.
Server-side operations (REST API calls) provide ``asset_id``. Worker-side
operations provide ``name`` or ``uri`` (workers do not have access to the
integer ``asset_id``).
