120
ctx context.Context,
121
request *p.InternalUpdateShardRequest,
123
>
query := d.Session.Query(templateUpdateShardQuery,
124
>
request.ShardInfo.Data,
125
>
request.ShardInfo.EncodingType.String(),
126
>
request.RangeID,
127
>
request.ShardID,
128
>
rowTypeShard,
129
>
rowTypeShardNamespaceID,
130
>
rowTypeShardWorkflowID,
131
>
rowTypeShardRunID,
132
>
defaultVisibilityTimestamp,
133
>
rowTypeShardTaskID,
134
>
request.PreviousRangeID,
135
>
).WithContext(ctx)
136
>
137
>
previous := make(map[string]any)
138
>
applied, err := query.MapScanCAS(previous)
139
>
if err != nil {
140
return gocql.ConvertError("UpdateShard", err)
141
}
142
144
var columns []string
145
for k, v := range previous {