PushBatch debug logs

Kaspiman · Apr 2, 2024 · 56ff7ed · 56ff7ed
1 parent f3e0683
commit 56ff7ed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin.go b/plugin.go
@@ -412,9 +412,9 @@ func (p *Plugin) PushBatch(ctx context.Context, j []jobsApi.Message) error {
 		ctxPush, cancel := context.WithTimeout(ctx, time.Second*time.Duration(p.cfg.Timeout))
 		err := d.(jobsApi.Driver).Push(ctxPush, j[i])
 		if err != nil {
-			cancel()
 			p.metrics.CountPushErr()
 			p.log.Error("job push batch error", zap.String("ID", j[i].ID()), zap.String("pipeline", ppl.Name()), zap.String("driver", ppl.Driver()), zap.Time("start", start), zap.Int64("elapsed", time.Since(start).Milliseconds()), zap.Error(err))
+			cancel()
 			return errors.E(op, err)
 		}