fix(job): fix jobmanager error

engine/lib/common.go

@@ -79,7 +79,7 @@ func WorkerTypeToJobType(t WorkerType) dfModel.JobType {
 	switch t {
 	case JobManager:
 		// jobmanager is the framework level job
-		// no job type
+		return dfModel.JobTypeJobManager
 	case CvsJobMaster, CvsTask:
 		return dfModel.JobTypeCVSDemo
 	case FakeJobMaster, FakeTask:

engine/model/job.go

@@ -28,24 +28,26 @@ type (
 // Define job type
 const (
 	JobTypeInvalid = JobType(iota)
+	// job type for job manager, only for inner use
+	JobTypeJobManager
 	JobTypeCVSDemo
 	JobTypeDM
 	JobTypeCDC
 	JobTypeFakeJob
 )
 
 var jobTypeName = map[int32]string{
-	1: "CVSDemo",
-	2: "DM",
-	3: "CDC",
-	4: "FakeJob",
+	2: "CVSDemo",
+	3: "DM",
+	4: "CDC",
+	5: "FakeJob",
 }
 
 var jobTypeValue = map[string]int32{
-	"CVSDemo": 1,
-	"DM":      2,
-	"CDC":     3,
-	"FakeJob": 4,
+	"CVSDemo": 2,
+	"DM":      3,
+	"CDC":     4,
+	"FakeJob": 5,
 }
 
 // MustJobTypeByName get job type by name. Panic if it fails.

engine/pkg/promutil/util.go

@@ -79,6 +79,11 @@ func HTTPHandlerForMetric() http.Handler {
 
 // NewFactory4Master return a Factory for jobmaster
 func NewFactory4Master(info tenant.ProjectInfo, jobType dfModel.JobType, jobID dfModel.JobID) Factory {
+	// Only for the jobmanager
+	if jobType == dfModel.JobTypeJobManager {
+		return NewFactory4Framework()
+	}
+
 	return NewFactory4MasterImpl(globalMetricRegistry, info, jobType, jobID)
 }