💥 Standalone activities support by maciejdudko · Pull Request #2158 · temporalio/sdk-go

maciejdudko · 2026-01-21T08:03:11Z

What was changed

Implemented support for running standalone activity tasks.
Client calls for standalone activities: execute, get result, describe, cancel, terminate, list, count.
Changes to TestActivityEnvironment to support executing activities as standalone.
💥 activity task tokens for tests have been changed, now testActivityToken (containing activityID and runID) are used to keep track of activities, instead of just activityID. Most users should not be affected, only if you're manually constructing task tokens in your tests.

Checklist

Closes Support standalone activities #2124
How was this tested:

New integration tests: TestIntegrationSuite/TestExecuteActivitySuite

Any docs updates needed?

Standalone activity docs are in progress.

client/client.go

internal/internal_activity_client.go

internal/internal_workflow_testsuite.go

internal/workflow_testsuite.go

internal/cmd/build/main.go

internal/client.go

test/activity_test.go

test/integration_test.go

.gitignore

internal/workflow_testsuite.go

internal/internal_task_handlers.go

client/client.go

internal/activity.go

internal/internal_activity_client.go

…summary,

…llows it

…er to 1.5.2-standalone-activity-server

cretz

Looks great, most of my concerns are minor

client/client.go

cretz · 2026-02-05T15:17:12Z

client/client.go

+		// Returns an ActivityExecutionAlreadyStarted error if an activity with the same ID already exists
+		// in this namespace, unless permitted by the specified ID conflict policy.
+		//
+		// ActivityHandle has the following methods:


Not sure we should have to keep an up-to-date list of the return type's interface methods here

We do this for ExecuteWorkflow, I think it's fine to keep it for consistency

ActivityHandle is not the same as WorkflowRun. When we add new operations for workflows, we make top-level methods, so we don't have to update that list.

Regardless, this is a perfect example of what I'm talking about. That list is missing GetWithOptions, but I wasn't around to predict that would happen then like I am now :-) It shouldn't be there either.

yeah, that's fair, one less thing to keep synchronized, removed

client/client.go

go.mod

cretz · 2026-02-05T15:35:02Z

internal/interceptor.go

+//
+// Exposed as: [go.temporal.io/sdk/interceptor.ClientExecuteActivityInput]
+type ClientExecuteActivityInput struct {
+	Options      *ClientStartActivityOptions


FWIW, it is arguable that this should not be a pointer, but since this matches other interceptor calls, no prob

internal/internal_activity_client.go

cretz · 2026-02-05T15:59:45Z

internal/internal_activity_client.go

+	if e, ok := err.(*serviceerror.ActivityExecutionAlreadyStarted); ok &&
+		in.Options.ActivityIDConflictPolicy == enumspb.ACTIVITY_ID_CONFLICT_POLICY_USE_EXISTING {


This conditional doesn't really make sense. If the conflict policy was use existing, you'd never get this error. Rather, we need to confirm if, like workflows, we default to already-exists returning the handle (w/ WorkflowExecutionErrorWhenAlreadyStarted-like option to change it) or not.

Thanks for the callout, added ActivityExecutionErrorWhenAlreadyStarted to mirror workflow

This works for me, though may want to confirm with others on the standalone activity team they have no concerns

Discussed offline, removing ActivityExecutionErrorWhenAlreadyStarted and instead relying on conflict policy, as that was added into workflows after WorkflowExecutionErrorWhenAlreadyStarted, we're diverging from mirroring workflows, but conflict policy should be sufficient here.

cretz · 2026-02-05T16:19:31Z

internal/internal_activity_client.go

+		RunId:      in.RunID,
+	}
+
+	resp, err := w.client.WorkflowService().PollActivityExecution(grpcCtx, request)


I think this needs to loop while there is no outcome

added a loop for resp.GetOutcome() != nil

…che results, clarify CompleteActivity* docs, add ActivityExecutionErrorWhenAlreadyStarted

cretz

Looks good, I have nothing blocking

cretz · 2026-02-06T16:25:30Z

client/client.go

+		// Returns an ActivityExecutionAlreadyStarted error if an activity with the same ID already exists
+		// in this namespace, unless permitted by the specified ID conflict policy.
+		//
+		// ActivityHandle has the following methods:


ActivityHandle is not the same as WorkflowRun. When we add new operations for workflows, we make top-level methods, so we don't have to update that list.

Regardless, this is a perfect example of what I'm talking about. That list is missing GetWithOptions, but I wasn't around to predict that would happen then like I am now :-) It shouldn't be there either.

cretz · 2026-02-06T16:27:01Z

internal/internal_activity_client.go

+	// NOTE: Experimental
+	//
+	// Exposed as: [go.temporal.io/sdk/client.ListActivitiesResult]
+	ClientListActivitiesResult struct {


Pedantic, but could be called ClientActivityList, but meh, this is fine

client/client.go

internal/internal_activity_client.go

cretz · 2026-02-06T16:56:18Z

internal/internal_activity_client.go

+	if e, ok := err.(*serviceerror.ActivityExecutionAlreadyStarted); ok &&
+		in.Options.ActivityIDConflictPolicy == enumspb.ACTIVITY_ID_CONFLICT_POLICY_USE_EXISTING {


This works for me, though may want to confirm with others on the standalone activity team they have no concerns

maciejdudko force-pushed the standalone-activities branch from 44508ad to 0dba4dd Compare January 22, 2026 23:34

maciejdudko marked this pull request as ready for review January 22, 2026 23:52

maciejdudko requested a review from a team as a code owner January 22, 2026 23:52

cretz reviewed Jan 23, 2026

View reviewed changes

yuandrew reviewed Jan 23, 2026

View reviewed changes

maciejdudko and others added 4 commits January 29, 2026 13:02

Implemented standalone activities

4e04e5c

Addressed some PR comments

f0042bf

Added interceptor methods and ActivityHandleBase.

f0a9fe3

ClientGetActivityHandleOptions

fc21cb8

yuandrew force-pushed the standalone-activities branch from 9eb5bc4 to fc21cb8 Compare January 29, 2026 23:29

Add docs, mark everything experimental, add details to go along with …

4637708

…summary,

yuandrew changed the title ~~Standalone activities support~~ 💥 Standalone activities support Jan 30, 2026

yuandrew added 4 commits January 30, 2026 15:52

Return err for ActivityExecutionAlreadyStarted, unless reuse policy a…

17f8336

…llows it

Intercept cancel/terminate/describe/PollActivityResult, bump dev serv…

55b60d6

…er to 1.5.2-standalone-activity-server

Merge branch 'master' into standalone-activities

979ffaa

go mod tidy

a7e3e0c

cretz reviewed Feb 5, 2026

View reviewed changes

yuandrew added 2 commits February 5, 2026 14:35

ClientListActivitiesResult, mirror ClientPollWorkflowUpdateOutput, ca…

bed337a

…che results, clarify CompleteActivity* docs, add ActivityExecutionErrorWhenAlreadyStarted

Fix condition

1a609f1

yuandrew mentioned this pull request Feb 5, 2026

Add standalone activities sample temporalio/samples-go#447

Merged

cretz approved these changes Feb 6, 2026

View reviewed changes

yuandrew added 6 commits February 9, 2026 09:55

upgrade CLI version to 1.6.1-server-1.31.0-150.0, fix test

ba4ed23

return err for ListActivities for future-proofing,

f2d47b0

add SA for dynamic config to docker yaml for CI

a610497

Skip SA integration test for docker tests

36bb519

remove extra quote

c409169

Missed a test to skip

ac36591

yuandrew merged commit 215920a into master Feb 10, 2026
16 checks passed

yuandrew deleted the standalone-activities branch February 10, 2026 00:18

		if e, ok := err.(*serviceerror.ActivityExecutionAlreadyStarted); ok &&
		in.Options.ActivityIDConflictPolicy == enumspb.ACTIVITY_ID_CONFLICT_POLICY_USE_EXISTING {

Conversation

maciejdudko commented Jan 21, 2026 • edited by yuandrew Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

What was changed

Checklist

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

cretz left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

cretz left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

maciejdudko commented Jan 21, 2026 •

edited by yuandrew

Loading