Fix issue temporalio#1703

protect the write to the map env.activities with env.locker
delanne · Nov 5, 2024 · 69b2c64 · 69b2c64
1 parent 9d74a90
commit 69b2c64
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/internal_workflow_testsuite.go b/internal/internal_workflow_testsuite.go
@@ -1412,6 +1412,8 @@ func (env *testWorkflowEnvironmentImpl) getActivityHandle(activityID, runID stri
 }
 
 func (env *testWorkflowEnvironmentImpl) setActivityHandle(activityID, runID string, handle *testActivityHandle) {
+	env.locker.Lock()
+	defer env.locker.Unlock()
 	env.activities[env.makeUniqueActivityID(activityID, runID)] = handle
 }