this repo has no description
improve logging in parallel scheduler
+3
-3
+3
-3
cmd/relay/stream/schedulers/parallel/parallel.go
+3
-3
cmd/relay/stream/schedulers/parallel/parallel.go
···
86
86
<-p.out
87
87
}
88
88
89
-
p.log.Info("parallel scheduler shutdown complete")
89
+
p.log.Info("parallel scheduler shutdown complete", "ident", p.ident)
90
90
}
91
91
92
92
type consumerTask struct {
···
138
138
p.itemsActive.Inc()
139
139
seq := work.val.Sequence()
140
140
if err := p.do(context.TODO(), work.val); err != nil {
141
-
p.log.Error("event handler failed", "err", err)
141
+
p.log.Error("event handler failed", "ident", p.ident, "err", err)
142
142
}
143
143
p.itemsProcessed.Inc()
144
144
145
145
p.lk.Lock()
146
146
rem, ok := p.active[work.repo]
147
147
if !ok {
148
-
p.log.Error("should always have an 'active' entry if a worker is processing a job")
148
+
p.log.Error("should always have an 'active' entry if a worker is processing a job", "ident", p.ident)
149
149
}
150
150
151
151
if len(rem) == 0 {