From 22459ee17a3ba0b4487f975b6ebe630cab2d9feb Mon Sep 17 00:00:00 2001 From: George Goldberg Date: Thu, 17 Aug 2017 15:05:17 +0100 Subject: PLT-7302: Aggregate Elasticsearch indexes over a certain age. (#7224) * PLT-7302: Aggregate Elasticsearch indexes over a certain age. This is done by a scheduled daily job, in order to keep the shard count to a sensible level in Elasticsearch. * Use map[string]string instead of StringMap --- jobs/jobs.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'jobs/jobs.go') diff --git a/jobs/jobs.go b/jobs/jobs.go index 1986b22b6..e478c5a19 100644 --- a/jobs/jobs.go +++ b/jobs/jobs.go @@ -16,7 +16,7 @@ const ( CANCEL_WATCHER_POLLING_INTERVAL = 5000 ) -func CreateJob(jobType string, jobData map[string]interface{}) (*model.Job, *model.AppError) { +func CreateJob(jobType string, jobData map[string]string) (*model.Job, *model.AppError) { job := model.Job{ Id: model.NewId(), Type: jobType, @@ -70,9 +70,9 @@ func SetJobError(job *model.Job, jobError *model.AppError) *model.AppError { job.Status = model.JOB_STATUS_ERROR job.Progress = -1 if job.Data == nil { - job.Data = make(map[string]interface{}) + job.Data = make(map[string]string) } - job.Data["error"] = jobError + job.Data["error"] = jobError.Error() if result := <-Srv.Store.Job().UpdateOptimistically(job, model.JOB_STATUS_IN_PROGRESS); result.Err != nil { return result.Err -- cgit v1.2.3-1-g7c22