1193
1194
// Range is successfully updated in cassandra now update shard context to reflect new range
1195
>
s.contextTaggedLogger.Info("Range updated for shardID",
context_impl.go
1196
>
tag.ShardRangeID(updatedShardInfo.RangeId),
1197
>
tag.PreviousShardRangeID(s.shardInfo.RangeId),
1198
>
)
1199
>
1200
>
s.shardInfo = trimShardInfo(s.config, s.clusterMetadata.GetAllClusterInfo(), s.copyShardInfo(updatedShardInfo))
1201
>
s.taskKeyManager.setRangeID(s.shardInfo.RangeId)
1202
>
1203
>
return nil
1204
}
1205