aboutsummaryrefslogtreecommitdiff
path: root/pkg/worker
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/worker')
-rw-r--r--pkg/worker/list_processor.go7
1 files changed, 6 insertions, 1 deletions
diff --git a/pkg/worker/list_processor.go b/pkg/worker/list_processor.go
index 8169e4e..c9c20a9 100644
--- a/pkg/worker/list_processor.go
+++ b/pkg/worker/list_processor.go
@@ -4,6 +4,8 @@ import (
"context"
"errors"
"sync"
+
+ "github.com/sirupsen/logrus"
)
type (
@@ -26,6 +28,7 @@ type (
listProcessorWorker[T any] struct {
listProcessor ListProcessor[T]
+ logrus *logrus.Entry
scheduler *Scheduler
}
)
@@ -33,10 +36,12 @@ type (
func NewWorkerFromListProcessor[T any](
listProcessor ListProcessor[T],
scheduler *Scheduler,
+ logrus *logrus.Entry,
) Worker {
return &listProcessorWorker[T]{
listProcessor: listProcessor,
scheduler: scheduler,
+ logrus: logrus,
}
}
@@ -75,7 +80,7 @@ func (l *listProcessorWorker[T]) Start(ctx context.Context) error {
defer l.scheduler.Return()
defer wg.Done()
if err := l.listProcessor.Process(ctx, v); err != nil && !errors.Is(err, context.Canceled) {
- println("Err", err.Error())
+ l.logrus.WithError(err).Error("Error processing batch")
}
}(v)
}