diff --git a/lib/rob/schedulers/v2/sink/sink.go b/lib/rob/schedulers/v2/sink/sink.go index a3987e5d144b4a86cf944a038dd513ff81b1c4ee..1a00fd0bd8415b6e04b889bb8b51de69e8e6b7df 100644 --- a/lib/rob/schedulers/v2/sink/sink.go +++ b/lib/rob/schedulers/v2/sink/sink.go @@ -2,6 +2,7 @@ package sink import ( "github.com/google/uuid" + "log" "sync" "time" @@ -33,6 +34,7 @@ func NewSink(id uuid.UUID) *Sink { func (T *Sink) schedule(j job.Stalled) bool { if T.active == j.User { + log.Println("couldn't schedule because user is active") return false } @@ -60,6 +62,7 @@ func (T *Sink) schedule(j job.Stalled) bool { } if s.User == j.User { + log.Println("couldn't schedule because user is scheduled") return false } stride += 1