diff options
Diffstat (limited to 'pkg/worker')
-rw-r--r-- | pkg/worker/list_processor.go | 7 |
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) } |