增加日志

manager/internal/jobmgr/job/state/adjusting.go

@@ -7,6 +7,7 @@ import (
 	"sync"
 	"time"
 
+	"gitlink.org.cn/cloudream/common/pkgs/logger"
 	schsdk "gitlink.org.cn/cloudream/common/sdks/scheduler"
 	cdssdk "gitlink.org.cn/cloudream/common/sdks/storage"
 	schglb "gitlink.org.cn/cloudream/scheduler/common/globals"
@@ -63,6 +64,8 @@ func (s *Adjusting) do(rtx jobmgr.JobStateRunContext, jo *jobmgr.Job) error {
 	}
 	s.targetCCInfo = ccInfo
 
+	logger.WithField("JobID", jo.JobID).Infof("job is scheduled to %v(%v)", ccInfo.Name, ccInfo.CCID)
+
 	stgCli, err := schglb.CloudreamStoragePool.Acquire()
 	if err != nil {
 		return fmt.Errorf("new cds client: %w", err)

manager/internal/jobmgr/jobmgr.go

@@ -76,7 +76,7 @@ func (m *Manager) ChangeState(job *Job, state JobState) {
 	mgrJob.state = state
 
 	go func() {
-		logger.Infof("job %v state changed: %T -> %T", job.JobID, lastState, state)
+		logger.WithField("JobID", job.JobID).Infof("state changed: %T -> %T", lastState, state)
 
 		state.Run(JobStateRunContext{
 			Mgr:       m,