diff --git a/bootstrapwatch/bootstrap.go b/bootstrapwatch/bootstrap.go index 4ba8320c..926b14fe 100644 --- a/bootstrapwatch/bootstrap.go +++ b/bootstrapwatch/bootstrap.go @@ -119,7 +119,6 @@ func Boot(ctx context.Context, root *hroot.State, bootopts bootstrap.BootOpts, c log.Error("watcher close:", err) } close(sigCh) - pool.Stop() }, } diff --git a/cmd/heph/init.go b/cmd/heph/init.go index 25b7840c..3ba4fed4 100644 --- a/cmd/heph/init.go +++ b/cmd/heph/init.go @@ -70,8 +70,6 @@ func schedulerInit(ctx context.Context, postBoot func(bootstrap.BaseBootstrap) e <-gb.Wait() } log.Tracef("All pool items finished") - - bs.Scheduler.Pool.Stop() } if bs.Summary != nil { @@ -104,8 +102,6 @@ func bootstrapInit(ctx context.Context) (bootstrap.Bootstrap, error) { Finalizers.RegisterWithErr(func(err error) { bs.Finalizers.Run(err) - - bs.Pool.Stop() }) return bs, nil