Skip to content

Commit 147489a

Browse files
authored
[shard-distributor] Fix: forgot to update a mapper (cadence-workflow#7242)
What changed? Added the Done state to the mapper Why? Forget it when I added the new status How did you test it? Potential risks Release notes Documentation Changes
1 parent 5d74f8f commit 147489a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

common/types/mapper/proto/sharddistributor.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,8 @@ func FromShardDistributorExecutorHeartbeatRequest(t *types.ExecutorHeartbeatRequ
104104
status = sharddistributorv1.ShardStatus_SHARD_STATUS_INVALID
105105
case types.ShardStatusREADY:
106106
status = sharddistributorv1.ShardStatus_SHARD_STATUS_READY
107+
case types.ShardStatusDONE:
108+
status = sharddistributorv1.ShardStatus_SHARD_STATUS_DONE
107109
default:
108110
status = sharddistributorv1.ShardStatus_SHARD_STATUS_INVALID
109111
}

0 commit comments

Comments
 (0)