Skip to content

Add asset state store API to the Java SDK - #74217

Draft
FrankYang0529 wants to merge 1 commit into
apache:mainfrom
FrankYang0529:java-sdk-asset-state-store
Draft

FrankYang0529 wants to merge 1 commit into
apache:mainfrom
FrankYang0529:java-sdk-asset-state-store

Conversation

@FrankYang0529

@FrankYang0529 FrankYang0529 commented Oct 5, 2026 •

Copy link
Copy Markdown
Member
  • Add client.getAssetStateStore(). byName(name) or byUri(uri) returns an AssetStateStore with get, set, delete and clear. The JVM does not receive the inlets and outlets declared on the @task.stub, so the SDK cannot know which assets the task uses. The task code passes the asset's name or URI instead.
  • The supervisor answers ASSET_STORE_NOT_FOUND when the key or the asset does not exist. The get returns null for both cases. For any other error, get throws ApiError.
  • byName and byUri reject an empty string.

Was generative AI tooling used to co-author this PR?
  • Yes - Claude Code

  • Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
  • For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
  • When adding dependency, check compliance with the ASF 3rd Party License Policy.
  • For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

Signed-off-by: PoAn Yang <payang@apache.org>
@FrankYang0529
FrankYang0529 force-pushed the java-sdk-asset-state-store branch from 0be4c8e to 345f6ad Compare October 9, 2026 02:43

This branch has not been deployed

No deployments
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant