fix: retrynum-1

logikoisto · logikoisto · commit 5901ab3b779e · 2024-01-21T14:07:19.000Z
diff --git a/common/bizflow/graph.go b/common/bizflow/graph.go
@@ -90,6 +90,7 @@ func (g *Graph) Run(ctx context.Context) error {
 			g.tryStop(it)
 		case RetryableError:
 			if it.retryNum > 0 {
+				it.retryNum -= 1
 				g.e.workPool.Submit(func() { g.work(it) })
 			}
 		case NonRetryable:

Original file line number	Diff line number	Diff line change
`@@ -90,6 +90,7 @@ func (g *Graph) Run(ctx context.Context) error {`
`90`	`90`	`g.tryStop(it)`
`91`	`91`	`case RetryableError:`
`92`	`92`	`if it.retryNum > 0 {`
	`93`	`+ it.retryNum -= 1`
`93`	`94`	`g.e.workPool.Submit(func() { g.work(it) })`
`94`	`95`	`}`
`95`	`96`	`case NonRetryable:`