Skip to content

Commit

Permalink
linter
Browse files Browse the repository at this point in the history
  • Loading branch information
ychebotarev committed Feb 10, 2025
1 parent d12c1df commit e85250a
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions service/history/workflow/matcher/activity_evaluator.go
Original file line number Diff line number Diff line change
Expand Up @@ -242,15 +242,16 @@ func (m *ActivityMatchEvaluator) compareActivityStatus(status string, operator s
if m.ai.Paused {
return compareQueryString(status, "Paused", operator, activityStatusColName)
}
switch workflow.GetActivityState(m.ai) {
switch workflow.GetActivityState(m.ai) { //nolint:exhaustive
case enumspb.PENDING_ACTIVITY_STATE_CANCEL_REQUESTED:
return compareQueryString(status, "Cancelled", operator, activityStatusColName)
case enumspb.PENDING_ACTIVITY_STATE_STARTED:
return compareQueryString(status, "Running", operator, activityStatusColName)
case enumspb.PENDING_ACTIVITY_STATE_SCHEDULED:
return compareQueryString(status, "Scheduled", operator, activityStatusColName)
default:
return false, NewMatcherError("unknown activity status: %s", status)
}
return false, NewMatcherError("unknown activity status: %s", status)
}

func (m *ActivityMatchEvaluator) compareActivityTaskQueue(taskQueue string, operator string) (bool, error) {
Expand Down

0 comments on commit e85250a

Please sign in to comment.