diff --git a/internal/route/provider/provider.go b/internal/route/provider/provider.go index e3a6c216..be22c639 100644 --- a/internal/route/provider/provider.go +++ b/internal/route/provider/provider.go @@ -110,8 +110,6 @@ func (p *Provider) Start(parent task.Parent) gperr.Error { t.Subtask("event_queue", false), providerEventFlushInterval, func(events []events.Event) { - routesTask.FinishAndWait("reload routes") - routesTask = t.Subtask("routes", false) handler := p.newEventHandler() // routes' lifetime should follow the provider's lifetime handler.Handle(routesTask, events) diff --git a/internal/route/route.go b/internal/route/route.go index 62c41f5e..f09af579 100644 --- a/internal/route/route.go +++ b/internal/route/route.go @@ -227,7 +227,7 @@ func (r *Route) Finish(reason any) { if r.impl == nil { return } - r.impl.Finish(reason) + r.impl.Task().FinishAndWait(reason) r.impl = nil }