feat(scheduler): add error logging on run interruption

pkg/scheduler/listener.go

@@ -5,6 +5,8 @@ package scheduler
 import (
 	"context"
 	"time"
+
+	"github.com/scylladb/go-log"
 )
 
 // Listener specifies pluggable hooks for scheduler events.
@@ -74,3 +76,26 @@ func (l nopListener[K]) OnSleep(context.Context, K, time.Duration) {
 func NopListener[K comparable]() Listener[K] {
 	return nopListener[K]{}
 }
+
+type errorLogListener[K comparable] struct {
+	nopListener[K]
+	logger log.Logger
+}
+
+func (l errorLogListener[K]) OnRunError(ctx *RunContext[K], err error) {
+	l.logger.Error(ctx, "OnRunError", "key", ctx.Key, "retry", ctx.Retry, "error", err)
+}
+
+func (l errorLogListener[K]) OnRunWindowEnd(ctx *RunContext[K]) {
+	l.logger.Info(ctx, "OnRunWindowEnd", "key", ctx.Key, "retry", ctx.Retry)
+}
+
+func (l errorLogListener[K]) OnRunStop(ctx *RunContext[K]) {
+	l.logger.Info(ctx, "OnRunStop", "key", ctx.Key, "retry", ctx.Retry)
+}
+
+func ErrorLogListener[K comparable](logger log.Logger) Listener[K] {
+	return errorLogListener[K]{
+		logger: logger,
+	}
+}

pkg/service/scheduler/listener.go

@@ -21,7 +21,7 @@ type schedulerListener struct {
 
 func newSchedulerListener(find func(key Key) (taskInfo, bool), logger log.Logger) schedulerListener {
 	return schedulerListener{
-		Listener: scheduler.NopListener[Key](),
+		Listener: scheduler.ErrorLogListener[Key](logger),
 		find:     find,
 		logger:   logger,
 	}