Skip to content

Commit

Permalink
bugfix sticky query for old client (#481)
Browse files Browse the repository at this point in the history
  • Loading branch information
wxing1292 authored Dec 22, 2017
1 parent c3a2b1e commit 62c7c29
Showing 1 changed file with 8 additions and 1 deletion.
9 changes: 8 additions & 1 deletion service/matching/matchingEngine.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ import (
workflow "github.com/uber/cadence/.gen/go/shared"
"github.com/uber/cadence/client/history"
"github.com/uber/cadence/common"
"github.com/uber/cadence/common/client"
"github.com/uber/cadence/common/logging"
"github.com/uber/cadence/common/metrics"
"github.com/uber/cadence/common/persistence"
Expand Down Expand Up @@ -275,8 +276,14 @@ pollLoop:
return emptyPollForDecisionTaskResponse, nil
}

clientFeature := client.NewFeatureImpl(
mutableStateResp.GetClientLibraryVersion(),
mutableStateResp.GetClientFeatureVersion(),
mutableStateResp.GetClientImpl(),
)

isStickyEnabled := false
if len(mutableStateResp.StickyTaskList.GetName()) != 0 {
if len(mutableStateResp.StickyTaskList.GetName()) != 0 && clientFeature.SupportStickyQuery() {
isStickyEnabled = true
}
resp := &h.RecordDecisionTaskStartedResponse{
Expand Down

0 comments on commit 62c7c29

Please sign in to comment.