diff --git a/job/job.go b/job/job.go index d357b27a..6a29abae 100644 --- a/job/job.go +++ b/job/job.go @@ -272,7 +272,8 @@ func (j *JobRuntime) end() { j.Job.statusRing.Add(j.History) j.Context.Counter("job", "name", j.Job.Name, "id", j.Job.ResourceID, "resource", j.Job.ResourceType, "status", j.History.Status).Add(1) - j.Context.Histogram("job_duration", context.LongLatencyBuckets, "name", j.Job.Name, "id", j.Job.ResourceID, "resource", j.Job.ResourceType, "status", j.History.Status).Since(j.History.TimeStart) + j.Context.Histogram("job_duration", context.LongLatencyBuckets, "name", j.Job.Name, "id", j.Job.ResourceID, "resource", j.Job.ResourceType, "status", j.History.Status). + Since(j.History.TimeStart) } func (j *JobRuntime) Failf(message string, args ...interface{}) { @@ -562,7 +563,6 @@ func (j *Job) GetResourcedName() string { func (j *Job) AddToScheduler(cronRunner *cron.Cron) error { echo.RegisterCron(cronRunner) - cronRunner.Start() schedule := j.Schedule if override, ok := j.GetProperty("schedule"); ok {