From bc59245fe10efaed9d51b56900192527ed733435 Mon Sep 17 00:00:00 2001 From: Xiao Renhao Date: Wed, 6 Jan 2021 10:54:41 +0800 Subject: [PATCH] fix: gracefully quit jobWrapper SkipIfStillRunning --- chain.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/chain.go b/chain.go index 9565b418..9c087b7b 100644 --- a/chain.go +++ b/chain.go @@ -82,8 +82,8 @@ func SkipIfStillRunning(logger Logger) JobWrapper { return FuncJob(func() { select { case v := <-ch: + defer func() { ch <- v }() j.Run() - ch <- v default: logger.Info("skip") }