diff options
author | Valery Piashchynski <[email protected]> | 2021-08-12 13:25:36 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-08-12 13:25:36 +0300 |
commit | ecbfc5c5265a9895f4e371ce4388f64df8714e63 (patch) | |
tree | df0749155487eae6bcdbb2456885131a21916f4d /plugins/jobs/plugin.go | |
parent | 4169e8374f581ba2213f8cd1833cc6b9b84438e8 (diff) |
Remove unneeded options, complete tests for the ephemeral, update proto
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/plugin.go')
-rw-r--r-- | plugins/jobs/plugin.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go index e2fffda7..26015516 100644 --- a/plugins/jobs/plugin.go +++ b/plugins/jobs/plugin.go @@ -246,13 +246,14 @@ func (p *Plugin) Serve() chan error { //nolint:gocognit p.putPayload(exec) errNack := jb.Nack() if errNack != nil { - p.log.Error("negatively acknowledge failed, job might be lost", "error", errNack) + p.log.Error("negatively acknowledge failed, job might be lost", "root error", err, "error nack", errNack) + continue } + + p.log.Error("job negatively acknowledged", "error", err) continue } - // free the resources - jb.Recycle() // return payload p.putPayload(exec) } |