summaryrefslogtreecommitdiffstats
path: root/jobs/jobs.go
diff options
context:
space:
mode:
authorCorey Hulen <corey@hulen.com>2017-09-25 13:30:33 -0700
committerGitHub <noreply@github.com>2017-09-25 13:30:33 -0700
commit81c18a01bd22437457da04b6cdb8d409beb54446 (patch)
tree1c1a28dc72fe8685259870e53643de9f558dad79 /jobs/jobs.go
parent1bf2a2e8d5a552d23e16379e73c2d4aaefc9368f (diff)
downloadchat-81c18a01bd22437457da04b6cdb8d409beb54446.tar.gz
chat-81c18a01bd22437457da04b6cdb8d409beb54446.tar.bz2
chat-81c18a01bd22437457da04b6cdb8d409beb54446.zip
PLT-7542 Converting LDAP sync to the job server (#7452)
* PLT-7542 Converting LDAP sync to the job server * Fixing minor issues * Fixing build failure * Translate error message * Translate error message * Translate error message * Translate error message * Fixing merge * Fixing bad merge
Diffstat (limited to 'jobs/jobs.go')
-rw-r--r--jobs/jobs.go12
1 files changed, 11 insertions, 1 deletions
diff --git a/jobs/jobs.go b/jobs/jobs.go
index 6e1230291..a51780865 100644
--- a/jobs/jobs.go
+++ b/jobs/jobs.go
@@ -11,6 +11,7 @@ import (
l4g "github.com/alecthomas/log4go"
"github.com/mattermost/mattermost-server/model"
+ "github.com/mattermost/mattermost-server/utils"
)
const (
@@ -37,6 +38,14 @@ func CreateJob(jobType string, jobData map[string]string) (*model.Job, *model.Ap
return &job, nil
}
+func GetJob(id string) (*model.Job, *model.AppError) {
+ if result := <-Srv.Store.Job().Get(id); result.Err != nil {
+ return nil, result.Err
+ } else {
+ return result.Data.(*model.Job), nil
+ }
+}
+
func ClaimJob(job *model.Job) (bool, *model.AppError) {
if result := <-Srv.Store.Job().UpdateStatusOptimistically(job.Id, model.JOB_STATUS_PENDING, model.JOB_STATUS_IN_PROGRESS); result.Err != nil {
return false, result.Err
@@ -73,7 +82,8 @@ func SetJobError(job *model.Job, jobError *model.AppError) *model.AppError {
if job.Data == nil {
job.Data = make(map[string]string)
}
- job.Data["error"] = jobError.Error()
+ jobError.Translate(utils.T)
+ job.Data["error"] = jobError.Message + " (" + jobError.DetailedError + ")"
if result := <-Srv.Store.Job().UpdateOptimistically(job, model.JOB_STATUS_IN_PROGRESS); result.Err != nil {
return result.Err