jason810496 opened a new pull request, #72851: URL: https://github.com/apache/airflow/pull/72851
Backport of #72127 to `v3-3-test`. ## Why Async tasks and watcher triggers need awaitable asset state store accessors so API requests do not block their event loop. ## What - Backport `aget`, `aset`, `adelete`, and `aclear`, their tests, and documentation. - Resolve the `context.py` conflict by preserving 3.3's lazy message imports in the shared helpers and moving the shared `ToSupervisor` annotation import under `TYPE_CHECKING`. ## Validation - All 176 tests in `task-sdk/tests/task_sdk/execution_time/test_context.py` passed in the cached Python 3.10 CI image with this branch's Task SDK, core, shared libraries, and test utilities mounted. - `prek run --from-ref upstream/v3-3-test --stage pre-commit` passed, including Task SDK mypy. Manual hooks had no applicable checks. - Fresh Breeze image builds were blocked by Docker Hub timeouts; the tests used the cached image instead. The broader CI suites remain for GitHub Actions. Inherited backend async limitations are tracked in #72129 and #72131, as in the original PR. --- ##### Was generative AI tooling used to co-author this PR? - [x] Yes, with help of Codex (GPT-6) following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
