Allow passed content to be of type LHVariableValue

littlehorse-enterprises · Dec 19, 2024 · 7fdd2e7 · 7fdd2e7
1 parent 1f13204
commit 7fdd2e7
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
diff --git a/sdk-go/littlehorse/lh_variables.go b/sdk-go/littlehorse/lh_variables.go
@@ -146,6 +146,11 @@ func InterfaceToVarVal(someInterface interface{}) (*lhproto.VariableValue, error
 	out := &lhproto.VariableValue{}
 	var err error
 
+	interfaceAsVarVal, isVarVal := someInterface.(*lhproto.VariableValue)
+	if isVarVal {
+		return interfaceAsVarVal, nil
+	}
+
 	isPtr, _ := GetIsPtrAndType(reflect.TypeOf(someInterface))
 	if someInterface == nil {
 		return &lhproto.VariableValue{}, nil

diff --git a/sdk-go/littlehorse/task_worker_internal.go b/sdk-go/littlehorse/task_worker_internal.go
@@ -431,12 +431,12 @@ func (m *serverConnectionManager) doTaskHelper(task *lhproto.ScheduledTask) *lhp
 		if errorReflect.Interface() != nil {
 			// Check if the error is an LHTaskException
 			if lhtErr, ok := errorReflect.Interface().(*LHTaskException); ok {
-				taskErrVarVal, err := InterfaceToVarVal(lhtErr.Content)
+				taskErrContent, err := InterfaceToVarVal(lhtErr.Content)
 
 				if err != nil {
-					msg := "Failed to serialize task error content: " + err.Error()
+					msg := "LH_SDK_GO_ERR: Failed to serialize task error content passed from task worker: " + err.Error()
 
-					taskErrVarVal = &lhproto.VariableValue{
+					taskErrContent = &lhproto.VariableValue{
 						Value: &lhproto.VariableValue_Str{
 							Str: msg,
 						},
@@ -447,7 +447,7 @@ func (m *serverConnectionManager) doTaskHelper(task *lhproto.ScheduledTask) *lhp
 					Exception: &lhproto.LHTaskException{
 						Name:    lhtErr.Name,
 						Message: lhtErr.Message,
-						Content: taskErrVarVal,
+						Content: taskErrContent,
 					},
 				}
 			} else {