diff --git a/internal/route/fileserver.go b/internal/route/fileserver.go index ee285d30..d80b5918 100644 --- a/internal/route/fileserver.go +++ b/internal/route/fileserver.go @@ -128,7 +128,9 @@ func (s *FileServer) Start(parent task.Parent) gperr.Error { ep := entrypoint.FromCtx(parent.Context()) if ep == nil { - return gperr.New("entrypoint not initialized") + err := gperr.New("entrypoint not initialized") + s.task.Finish(err) + return err } ep.AddRoute(s) return nil diff --git a/internal/route/reverse_proxy.go b/internal/route/reverse_proxy.go index 1f2c1254..03ae8710 100755 --- a/internal/route/reverse_proxy.go +++ b/internal/route/reverse_proxy.go @@ -165,7 +165,9 @@ func (r *ReveseProxyRoute) Start(parent task.Parent) gperr.Error { ep := entrypoint.FromCtx(parent.Context()) if ep == nil { - return gperr.New("entrypoint not initialized") + err := gperr.New("entrypoint not initialized") + r.task.Finish(err) + return err } if r.UseLoadBalance() { diff --git a/internal/route/stream.go b/internal/route/stream.go index 1d10f17a..ea26ed5a 100755 --- a/internal/route/stream.go +++ b/internal/route/stream.go @@ -84,7 +84,9 @@ func (r *StreamRoute) Start(parent task.Parent) gperr.Error { ep := entrypoint.FromCtx(parent.Context()) if ep == nil { - return gperr.New("entrypoint not initialized") + err := gperr.New("entrypoint not initialized") + r.task.Finish(err) + return err } ep.AddRoute(r) return nil