Access last run details (#342)

temporalio · Jan 20, 2021 · 3e18a77 · 3e18a77
1 parent f1b6a72
commit 3e18a77
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/internal/workflow.go b/internal/workflow.go
@@ -1505,3 +1505,8 @@ func convertRetryPolicy(retryPolicy *RetryPolicy) *commonpb.RetryPolicy {
 		NonRetryableErrorTypes: retryPolicy.NonRetryableErrorTypes,
 	}
 }
+
+// GetLastCompletionResultFromWorkflowInfo returns value of last completion result.
+func GetLastCompletionResultFromWorkflowInfo(info *WorkflowInfo) *commonpb.Payloads {
+	return info.lastCompletionResult
+}
diff --git a/internalbindings/internalbindings.go b/internalbindings/internalbindings.go
@@ -32,6 +32,7 @@
 package internalbindings
 
 import (
+	commonpb "go.temporal.io/api/common/v1"
 	failurepb "go.temporal.io/api/failure/v1"
 	"go.temporal.io/sdk/converter"
 	"go.temporal.io/sdk/internal"
@@ -87,3 +88,8 @@ func ConvertErrorToFailure(err error, dc converter.DataConverter) *failurepb.Fai
 func ConvertFailureToError(failure *failurepb.Failure, dc converter.DataConverter) error {
 	return internal.ConvertFailureToError(failure, dc)
 }
+
+// GetLastCompletionResult returns last completion result from workflow.
+func GetLastCompletionResult(env WorkflowEnvironment) *commonpb.Payloads {
+	return internal.GetLastCompletionResultFromWorkflowInfo(env.WorkflowInfo())
+}