fixes

Author: gow

api/historyservice/v1/request_response.pb.go

@@ -7,6 +7,7 @@ import (
 	"io"
 	"log"
 	"reflect"
+	"runtime/debug"
 	"slices"
 	"strings"
 
@@ -144,6 +145,8 @@ func verifyFieldExists(t reflect.Type, path string) {
 		fieldName := codegen.SnakeCaseToPascalCase(part)
 		f, ok := t.FieldByName(fieldName)
 		if !ok {
+			fmt.Printf("\nstack trace: path: [%s]\n", path)
+			fmt.Println(string(debug.Stack()))
 			codegen.Fatalf("%s has no field named %s", pathPrefix, fieldName)
 		}
 		if i == len(parts)-1 {

client/history/client_gen.go

@@ -1318,7 +1318,7 @@ message UpdateWorkflowExecutionOptionsResponse {
 }
 
 message PauseWorkflowExecutionRequest {
-    option (routing).workflow_id = "pause_request.workflow_execution.workflow_id";
+    option (routing).workflow_id = "pause_request.workflow_id";
 
     // Namespace ID of the workflow which is being paused
     string namespace_id = 1;

cmd/tools/genrpcwrappers/main.go

@@ -19,7 +19,7 @@ func Invoke(
 	shard historyi.ShardContext,
 	workflowConsistencyChecker api.WorkflowConsistencyChecker,
 ) (resp *historyservice.PauseWorkflowExecutionResponse, retError error) {
-	shard.GetLogger().Warn(fmt.Sprintf("Pausing workflow execution %s/%s by %s", req.GetPauseRequest().GetId(), req.GetPauseRequest().GetRunId(), req.GetPauseRequest().GetIdentity()))
+	shard.GetLogger().Warn(fmt.Sprintf("Pausing workflow execution %s/%s by %s", req.GetPauseRequest().GetWorkflowId(), req.GetPauseRequest().GetRunId(), req.GetPauseRequest().GetIdentity()))
 	namespaceEntry, err := api.GetActiveNamespace(shard, namespace.ID(req.GetNamespaceId()))
 	if err != nil {
 		return nil, err
@@ -40,7 +40,7 @@ func Invoke(
 		nil,
 		definition.NewWorkflowKey(
 			namespaceID.String(),
-			pauseRequest.GetId(),
+			pauseRequest.GetWorkflowId(),
 			pauseRequest.GetRunId(),
 		),
 		func(workflowLease api.WorkflowLease) (*api.UpdateWorkflowAction, error) {

common/rpc/interceptor/logtags/history_service_server_gen.go

@@ -2626,7 +2626,7 @@ func (h *Handler) PauseWorkflowExecution(ctx context.Context, request *historyse
 		return nil, h.convertError(errNamespaceNotSet)
 	}
 
-	workflowID := request.GetPauseRequest().GetId()
+	workflowID := request.GetPauseRequest().GetWorkflowId()
 	shardContext, err := h.controller.GetShardByNamespaceWorkflow(namespaceID, workflowID)
 	if err != nil {
 		return nil, h.convertError(err)