fix: gracefully quit jobWrapper SkipIfStillRunning

robfig · Jan 6, 2021 · bc59245 · bc59245
1 parent 6a8421b
commit bc59245
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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")
 			}