summaryrefslogtreecommitdiff
path: root/plugins/server/plugin.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-06-03 19:43:39 +0300
committerValery Piashchynski <[email protected]>2021-06-03 19:43:39 +0300
commiteb04e1fb4e478ac7d695107d542aa48e36a7c32a (patch)
treef6f7a571c264b9cdace36ae1e0886e3eeda06ffc /plugins/server/plugin.go
parent3b06949c7e9a1fc5b2aec7529a97320a6f398535 (diff)
parentc3e57fd82d59be19b2c41479e9019c60a0afc28f (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.go12
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"))