diff --git a/poller/poller.go b/poller/poller.go index 8b3408e3..c653f881 100644 --- 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), } }