diff options
author | Valery Piashchynski <[email protected]> | 2021-06-03 19:43:39 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-06-03 19:43:39 +0300 |
commit | eb04e1fb4e478ac7d695107d542aa48e36a7c32a (patch) | |
tree | f6f7a571c264b9cdace36ae1e0886e3eeda06ffc /plugins/server/plugin.go | |
parent | 3b06949c7e9a1fc5b2aec7529a97320a6f398535 (diff) | |
parent | c3e57fd82d59be19b2c41479e9019c60a0afc28f (diff) |
Merge remote-tracking branch 'origin/master' into bug/fcgi_leads_to_npe
Diffstat (limited to 'plugins/server/plugin.go')
-rw-r--r-- | plugins/server/plugin.go | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go index aab9dcde..7f694f3c 100644 --- a/plugins/server/plugin.go +++ b/plugins/server/plugin.go @@ -235,6 +235,18 @@ func (server *Plugin) collectEvents(event interface{}) { if we, ok := event.(events.WorkerEvent); ok { switch we.Event { case events.EventWorkerError: + switch e := we.Payload.(type) { //nolint:gocritic + case error: + if errors.Is(errors.SoftJob, e) { + // get source error for the softjob error + server.log.Error(strings.TrimRight(e.(*errors.Error).Err.Error(), " \n\t")) + return + } + + // print full error for the other types of errors + server.log.Error(strings.TrimRight(e.Error(), " \n\t")) + return + } server.log.Error(strings.TrimRight(we.Payload.(error).Error(), " \n\t")) case events.EventWorkerLog: server.log.Debug(strings.TrimRight(utils.AsString(we.Payload.([]byte)), " \n\t")) |