diff --git a/services/tasks/local.go b/services/tasks/local.go index e33c30d98..340cdf4b8 100644 --- a/services/tasks/local.go +++ b/services/tasks/local.go @@ -118,6 +118,13 @@ func initFunc(ic *plugin.InitContext) (interface{}, error) { l.monitor.Monitor(t) } } + v2Tasks, err := l.v2Runtime.Tasks(ic.Context, true) + if err != nil { + return nil, err + } + for _, t := range v2Tasks { + l.monitor.Monitor(t) + } return l, nil }