Method SaveJobInfo

driver/common/store.go:361–369

(job JobListItemV2)

}

func (sm *StoreManager) SaveJobInfo(job JobListItemV2) error {
	key := fmt.Sprintf("dtleJobList/%v", job.JobId)
	jobBytes, err := json.Marshal(job)
	if err != nil {
		return fmt.Errorf("save %v to consul, marshal err : %v", key, err)
	}
	err = sm.consulStore.Put(key, jobBytes, nil)
	return err
}

func (sm *StoreManager) WaitOnJob(currentJob string, waitJob string, stopCh chan struct{}) error {
	waitCh := make(chan struct{}, 0)