Support AsyncWorkflowConfiguration decoding in admin cli

cadence-workflow · Feb 29, 2024 · 78d12f6 · 78d12f6
1 parent 6a39682
commit 78d12f6
Showing 1 changed file with 25 additions and 24 deletions.
diff --git a/tools/cli/admin_db_decode_thrift.go b/tools/cli/admin_db_decode_thrift.go
@@ -42,30 +42,31 @@ import (
 )
 
 var decodingTypes = map[string]func() codec.ThriftObject{
-	"shared.History":                 func() codec.ThriftObject { return &shared.History{} },
-	"shared.HistoryEvent":            func() codec.ThriftObject { return &shared.HistoryEvent{} },
-	"shared.HistoryBranch":           func() codec.ThriftObject { return &shared.HistoryBranch{} },
-	"shared.Memo":                    func() codec.ThriftObject { return &shared.Memo{} },
-	"shared.ResetPoints":             func() codec.ThriftObject { return &shared.ResetPoints{} },
-	"shared.BadBinaries":             func() codec.ThriftObject { return &shared.BadBinaries{} },
-	"shared.VersionHistories":        func() codec.ThriftObject { return &shared.VersionHistories{} },
-	"replicator.FailoverMarkers":     func() codec.ThriftObject { return &replicator.FailoverMarkers{} },
-	"history.ProcessingQueueStates":  func() codec.ThriftObject { return &history.ProcessingQueueStates{} },
-	"config.DynamicConfigBlob":       func() codec.ThriftObject { return &config.DynamicConfigBlob{} },
-	"sqlblobs.ShardInfo":             func() codec.ThriftObject { return &sqlblobs.ShardInfo{} },
-	"sqlblobs.DomainInfo":            func() codec.ThriftObject { return &sqlblobs.DomainInfo{} },
-	"sqlblobs.HistoryTreeInfo":       func() codec.ThriftObject { return &sqlblobs.HistoryTreeInfo{} },
-	"sqlblobs.WorkflowExecutionInfo": func() codec.ThriftObject { return &sqlblobs.WorkflowExecutionInfo{} },
-	"sqlblobs.ActivityInfo":          func() codec.ThriftObject { return &sqlblobs.ActivityInfo{} },
-	"sqlblobs.ChildExecutionInfo":    func() codec.ThriftObject { return &sqlblobs.ChildExecutionInfo{} },
-	"sqlblobs.SignalInfo":            func() codec.ThriftObject { return &sqlblobs.SignalInfo{} },
-	"sqlblobs.RequestCancelInfo":     func() codec.ThriftObject { return &sqlblobs.RequestCancelInfo{} },
-	"sqlblobs.TimerInfo":             func() codec.ThriftObject { return &sqlblobs.TimerInfo{} },
-	"sqlblobs.TaskInfo":              func() codec.ThriftObject { return &sqlblobs.TaskInfo{} },
-	"sqlblobs.TaskListInfo":          func() codec.ThriftObject { return &sqlblobs.TaskListInfo{} },
-	"sqlblobs.TransferTaskInfo":      func() codec.ThriftObject { return &sqlblobs.TransferTaskInfo{} },
-	"sqlblobs.TimerTaskInfo":         func() codec.ThriftObject { return &sqlblobs.TimerTaskInfo{} },
-	"sqlblobs.ReplicationTaskInfo":   func() codec.ThriftObject { return &sqlblobs.ReplicationTaskInfo{} },
+	"shared.History":                    func() codec.ThriftObject { return &shared.History{} },
+	"shared.HistoryEvent":               func() codec.ThriftObject { return &shared.HistoryEvent{} },
+	"shared.HistoryBranch":              func() codec.ThriftObject { return &shared.HistoryBranch{} },
+	"shared.Memo":                       func() codec.ThriftObject { return &shared.Memo{} },
+	"shared.ResetPoints":                func() codec.ThriftObject { return &shared.ResetPoints{} },
+	"shared.BadBinaries":                func() codec.ThriftObject { return &shared.BadBinaries{} },
+	"shared.VersionHistories":           func() codec.ThriftObject { return &shared.VersionHistories{} },
+	"replicator.FailoverMarkers":        func() codec.ThriftObject { return &replicator.FailoverMarkers{} },
+	"history.ProcessingQueueStates":     func() codec.ThriftObject { return &history.ProcessingQueueStates{} },
+	"config.DynamicConfigBlob":          func() codec.ThriftObject { return &config.DynamicConfigBlob{} },
+	"sqlblobs.ShardInfo":                func() codec.ThriftObject { return &sqlblobs.ShardInfo{} },
+	"sqlblobs.DomainInfo":               func() codec.ThriftObject { return &sqlblobs.DomainInfo{} },
+	"sqlblobs.HistoryTreeInfo":          func() codec.ThriftObject { return &sqlblobs.HistoryTreeInfo{} },
+	"sqlblobs.WorkflowExecutionInfo":    func() codec.ThriftObject { return &sqlblobs.WorkflowExecutionInfo{} },
+	"sqlblobs.ActivityInfo":             func() codec.ThriftObject { return &sqlblobs.ActivityInfo{} },
+	"sqlblobs.ChildExecutionInfo":       func() codec.ThriftObject { return &sqlblobs.ChildExecutionInfo{} },
+	"sqlblobs.SignalInfo":               func() codec.ThriftObject { return &sqlblobs.SignalInfo{} },
+	"sqlblobs.RequestCancelInfo":        func() codec.ThriftObject { return &sqlblobs.RequestCancelInfo{} },
+	"sqlblobs.TimerInfo":                func() codec.ThriftObject { return &sqlblobs.TimerInfo{} },
+	"sqlblobs.TaskInfo":                 func() codec.ThriftObject { return &sqlblobs.TaskInfo{} },
+	"sqlblobs.TaskListInfo":             func() codec.ThriftObject { return &sqlblobs.TaskListInfo{} },
+	"sqlblobs.TransferTaskInfo":         func() codec.ThriftObject { return &sqlblobs.TransferTaskInfo{} },
+	"sqlblobs.TimerTaskInfo":            func() codec.ThriftObject { return &sqlblobs.TimerTaskInfo{} },
+	"sqlblobs.ReplicationTaskInfo":      func() codec.ThriftObject { return &sqlblobs.ReplicationTaskInfo{} },
+	"shared.AsyncWorkflowConfiguration": func() codec.ThriftObject { return &shared.AsyncWorkflowConfiguration{} },
 }
 
 type decodeError struct {