summaryrefslogtreecommitdiff
path: root/plugins/jobs/plugin.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-08-12 13:25:36 +0300
committerValery Piashchynski <[email protected]>2021-08-12 13:25:36 +0300
commitecbfc5c5265a9895f4e371ce4388f64df8714e63 (patch)
treedf0749155487eae6bcdbb2456885131a21916f4d /plugins/jobs/plugin.go
parent4169e8374f581ba2213f8cd1833cc6b9b84438e8 (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.go7
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)
}