Skip to content

External Storage Integration: Activity worker, client - #3020

Open
cconstable wants to merge 1 commit into
extstore/foundationfrom
extstore/activity-client
Open

External Storage Integration: Activity worker, client#3020
cconstable wants to merge 1 commit into
extstore/foundationfrom
extstore/activity-client

Conversation

@cconstable

@cconstable cconstable commented Aug 19, 2026

Copy link
Copy Markdown
Contributor

What was changed

  • Main integration points are in WorkflowClientInternalImpl, HeartbeatContextImpl, and ActivityWorker.
  • Heartbeat store requests are canceled if they pass a timeout (as defined by the caller/heartbeat code).
  • Lot's of plumbing in other adjacent files.

Why?

  • Activity workers and clients should offload payloads with external storage.

Checklist

  • Added lots of tests.

@cconstable
cconstable changed the base branch from main to extstore/foundation August 19, 2026 18:01
@cconstable cconstable changed the title extstore/activity client External Storage Integration: Activity worker, client Aug 19, 2026
Comment on lines +145 to +148
public ListWorkflowExecutionsResponse listWorkflowExecutions(
ListWorkflowExecutionsRequest listRequest) {
return next.listWorkflowExecutions(listRequest);
}

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Addressed the previous concern of eagerly fetching external payloads #2978 (comment). They are now loaded lazily.

@cconstable
cconstable force-pushed the extstore/activity-client branch from 37ae3c7 to 7069249 Compare August 19, 2026 18:45

try {
sendReply(taskToken, result, metricsScope);
sendReply(taskToken, result, metricsScope, activityStorageTarget(pollResponse));

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Previous comment about pivoting this target based on standalone vs workflow activity has been addressed #2978 (comment)

activityStorageTarget delegates to storageTargetForActivityTask (which can be seen above)

@cconstable
cconstable marked this pull request as ready for review August 19, 2026 18:57
@cconstable
cconstable requested a review from a team as a code owner August 19, 2026 18:57
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant