diff --git a/job/scheduler.go b/job/scheduler.go index 80d9859fa..9b23a8f63 100644 --- a/job/scheduler.go +++ b/job/scheduler.go @@ -15,7 +15,7 @@ func HandleRepJob(id int64) { sm := &JobSM{JobID: id} err := sm.Init() if err != nil { - log.Errorf("Failed to initialize statemachine, error: %v") + log.Errorf("Failed to initialize statemachine, error: %v", err) err2 := dao.UpdateRepJobStatus(id, models.JobError) if err2 != nil { log.Errorf("Failed to update job status to ERROR, error:%v", err2) diff --git a/jobservice/jobservice b/jobservice/jobservice new file mode 100755 index 000000000..d5dc40d3a Binary files /dev/null and b/jobservice/jobservice differ diff --git a/utils/registry/auth/tokenhandler.go b/utils/registry/auth/tokenhandler.go index f546bac0c..55789aa55 100644 --- a/utils/registry/auth/tokenhandler.go +++ b/utils/registry/auth/tokenhandler.go @@ -186,12 +186,14 @@ func (s *standardTokenHandler) generateToken(realm, service string, scopes []str expiresIn = tk.ExpiresIn - t, err := time.Parse(time.RFC3339, tk.IssuedAt) - if err != nil { - log.Errorf("error occurred while parsing issued_at: %v", err) - err = nil - } else { - issuedAt = &t + if len(tk.IssuedAt) != 0 { + t, err := time.Parse(time.RFC3339, tk.IssuedAt) + if err != nil { + log.Errorf("error occurred while parsing issued_at: %v", err) + err = nil + } else { + issuedAt = &t + } } log.Debug("get token from token server") diff --git a/utils/registry/repository.go b/utils/registry/repository.go index 507634415..85c4abcf5 100644 --- a/utils/registry/repository.go +++ b/utils/registry/repository.go @@ -72,6 +72,9 @@ func NewRepositoryWithCredential(name, endpoint string, credential auth.Credenti } client, err := newClient(endpoint, "", credential, "repository", name, "pull", "push") + if err != nil { + return nil, err + } repository := &Repository{ Name: name,