Add reset to getters

temporalio · Sep 25, 2023 · 74ebe96 · 74ebe96
1 parent e2d4258
commit 74ebe96
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/internal/internal_event_handlers.go b/internal/internal_event_handlers.go
@@ -354,15 +354,15 @@ func (wc *workflowEnvironmentImpl) Send(msg *protocolpb.Message, opts ...msgSend
 	wc.outbox = append(wc.outbox, outboxEntry{msg: msg, eventPredicate: sendCfg.pred})
 }
 
-func (wc *workflowEnvironmentImpl) getNewSdkName() string {
+func (wc *workflowEnvironmentImpl) getNewSdkNameAndReset() string {
 	if wc.sdkNameUpdated {
 		wc.sdkNameUpdated = false
 		return wc.sdkName
 	}
 	return ""
 }
 
-func (wc *workflowEnvironmentImpl) getNewSdkVersion() string {
+func (wc *workflowEnvironmentImpl) getNewSdkVersionAndReset() string {
 	if wc.sdkVersionUpdated {
 		wc.sdkVersionUpdated = false
 		return wc.sdkVersion

diff --git a/internal/internal_task_handlers.go b/internal/internal_task_handlers.go
@@ -1772,8 +1772,8 @@ func (wth *workflowTaskHandlerImpl) completeWorkflow(
 		MeteringMetadata:           &commonpb.MeteringMetadata{NonfirstLocalActivityExecutionAttempts: nonfirstLAAttempts},
 		SdkMetadata: &sdk.WorkflowTaskCompletedMetadata{
 			LangUsedFlags: langUsedFlags,
-			SdkName:       eventHandler.getNewSdkName(),
-			SdkVersion:    eventHandler.getNewSdkVersion(),
+			SdkName:       eventHandler.getNewSdkNameAndReset(),
+			SdkVersion:    eventHandler.getNewSdkVersionAndReset(),
 		},
 		WorkerVersionStamp: &commonpb.WorkerVersionStamp{
 			BuildId:       wth.workerBuildID,