fix(poller): initial ready channel

2022-11-17 17:32:10 +08:00 · 2022-11-17 17:32:10 +08:00 · cab56996b7
parent a13ed0c52e
commit cab56996b7
1 changed files with 1 additions and 0 deletions
--- a/poller/poller.go
+++ b/poller/poller.go
@ -22,6 +22,7 @@ func New(cli client.Client, dispatch func(context.Context, *runnerv1.Task) error
 		routineGroup: newRoutineGroup(),
 		metric:       &metric{},
 		workerNum:    workerNum,
+		ready:        make(chan struct{}, 1),
 	}
 }