From 2192120d0f36afd6d1d486985cd84c7306a1263e Mon Sep 17 00:00:00 2001 From: yusing Date: Thu, 6 Feb 2025 17:29:47 +0800 Subject: [PATCH] fix route reload --- internal/route/provider/provider.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/internal/route/provider/provider.go b/internal/route/provider/provider.go index 2235a7b..6e94b28 100644 --- a/internal/route/provider/provider.go +++ b/internal/route/provider/provider.go @@ -84,8 +84,10 @@ func (p *Provider) MarshalText() ([]byte, error) { func (p *Provider) startRoute(parent task.Parent, r *route.Route) E.Error { err := r.Start(parent) if err != nil { + delete(p.routes, r.Alias) return err.Subject(r.Alias) } + p.routes[r.Alias] = r return nil } @@ -94,11 +96,8 @@ func (p *Provider) Start(parent task.Parent) E.Error { t := parent.Subtask("provider."+p.String(), false) errs := E.NewBuilder("routes error") - for alias, r := range p.routes { - if err := p.startRoute(t, r); err != nil { - errs.Add(err) - delete(p.routes, alias) - } + for _, r := range p.routes { + errs.Add(p.startRoute(t, r)) } eventQueue := events.NewEventQueue(