Reset stickyBacklog when pollForDecisionTask call failed (#660)

yycptt · web-flow · commit 759f50abfca0 · 2019-03-13T14:11:44.000-07:00
diff --git a/internal/internal_task_pollers.go b/internal/internal_task_pollers.go
@@ -672,6 +672,7 @@ func (wtp *workflowTaskPoller) poll() (*workflowTask, error) {
 		} else {
 			wtp.metricsScope.Counter(metrics.DecisionPollFailedCounter).Inc(1)
 		}
+		wtp.updateBacklog(request.TaskList.GetKind(), 0)
 		return nil, err
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -672,6 +672,7 @@ func (wtp workflowTaskPoller) poll() (workflowTask, error) {`
`672`	`672`	`} else {`
`673`	`673`	`wtp.metricsScope.Counter(metrics.DecisionPollFailedCounter).Inc(1)`
`674`	`674`	`}`
	`675`	`+ wtp.updateBacklog(request.TaskList.GetKind(), 0)`
`675`	`676`	`return nil, err`
`676`	`677`	`}`
`677`	`678`