|
|
|
@ -45,7 +45,7 @@ func newWorker(host string, model sdk.Model, runner sdk.Runner, logger Logger, s
|
|
|
|
|
|
|
|
|
|
func (w *worker) updateJob(job *jw.Job) { |
|
|
|
|
if job.Result == nil { |
|
|
|
|
job.Succeeded() |
|
|
|
|
_ = job.Succeeded() |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
job.Result.Host = w.host |
|
|
|
@ -100,7 +100,7 @@ func (w *worker) runJob(job *jw.Job) {
|
|
|
|
|
) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
job.Failed().SetError(fmt.Sprintf("PANIC ERROR RECOVERED: %v", data)) |
|
|
|
|
_ = job.Failed().SetError(fmt.Sprintf("PANIC ERROR RECOVERED: %v", data)) |
|
|
|
|
} |
|
|
|
|
}() |
|
|
|
|
|
|
|
|
@ -110,7 +110,7 @@ func (w *worker) runJob(job *jw.Job) {
|
|
|
|
|
if errors.As(err, &result) { |
|
|
|
|
job.Result = result |
|
|
|
|
} else { |
|
|
|
|
job.Failed().SetError(err.Error()) |
|
|
|
|
_ = job.Failed().SetError(err.Error()) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if w.logger != nil { |
|
|
|
|