fix

Author: maxdml

dbos/client.go

@@ -151,7 +151,7 @@ func (c *client) Enqueue(queueName, workflowName string, input any, opts ...Enqu
 	// Serialize input before storing in workflow status
 	encodedInput, err := serialize(params.workflowInput)
 	if err != nil {
-		return nil, newWorkflowExecutionError(workflowID, fmt.Errorf("failed to serialize workflow input: %w", err))
+		return nil, fmt.Errorf("failed to serialize workflow input: %w", err)
 	}
 
 	status := WorkflowStatus{

dbos/workflow.go

@@ -253,16 +253,17 @@ func (h *workflowPollingHandle[R]) GetResult(opts ...GetResultOption) (R, error)
 		return h.dbosContext.(*dbosContext).systemDB.awaitWorkflowResult(ctx, h.workflowID)
 	}, withRetrierLogger(h.dbosContext.(*dbosContext).logger))
 
-	// Deserialize the result
+	// Deserialize the result (but preserve any error from awaitWorkflowResult)
 	var result any
 	if encodedResult != nil {
 		encodedStr, ok := encodedResult.(string)
 		if !ok {
 			return *new(R), newWorkflowUnexpectedResultType(h.workflowID, "string (encoded)", fmt.Sprintf("%T", encodedResult))
 		}
-		result, err = deserialize(&encodedStr)
-		if err != nil {
-			return *new(R), fmt.Errorf("failed to deserialize workflow result: %w", err)
+		var deserErr error
+		result, deserErr = deserialize(&encodedStr)
+		if deserErr != nil {
+			return *new(R), fmt.Errorf("failed to deserialize workflow result: %w", deserErr)
 		}
 	}