tasks: Monitor v2 tasks in initFunc as well

darfux · fuweid · commit a1289d6b81ef · 2020-08-29T22:13:11.000+08:00
When containerd is restarted, only v1 tasks are monitored again. This leads to the lack of existing v2 task metrics. Signed-off-by: Li Yuxuan <liyuxuan04@baidu.com> (cherry picked from commit 4422ae3) Signed-off-by: Wei Fu <fuweid89@gmail.com>
diff --git 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
 }
 

Original file line number	Diff line number	Diff line change
`@@ -118,6 +118,13 @@ func initFunc(ic *plugin.InitContext) (interface{}, error) {`
`118`	`118`	`l.monitor.Monitor(t)`
`119`	`119`	`}`
`120`	`120`	`}`
	`121`	`+ v2Tasks, err := l.v2Runtime.Tasks(ic.Context, true)`
	`122`	`+ if err != nil {`
	`123`	`+ return nil, err`
	`124`	`+ }`
	`125`	`+ for _, t := range v2Tasks {`
	`126`	`+ l.monitor.Monitor(t)`
	`127`	`+ }`
`121`	`128`	`return l, nil`
`122`	`129`	`}`
`123`	`130`