diff --git a/lib/gat/pool/pool.go b/lib/gat/pool/pool.go index 01d7f14015679a9d804f312035936321728d1591..5fff28b15b75b1dd14363c82ab3b857d410a6e55 100644 --- a/lib/gat/pool/pool.go +++ b/lib/gat/pool/pool.go @@ -286,6 +286,7 @@ func (T *Pool) acquireServer(client *Client) *Server { server, ok := T.servers[serverID] T.mu.RUnlock() if !ok { + T.options.Pooler.Release(serverID) continue } return server diff --git a/lib/rob/schedulers/v2/sink/sink.go b/lib/rob/schedulers/v2/sink/sink.go index 6e590f9dae8e910275ab1330ab40a3267d6a2248..5eadc056cd6e7d8abf0f56ef1682b681c5ab6aaa 100644 --- a/lib/rob/schedulers/v2/sink/sink.go +++ b/lib/rob/schedulers/v2/sink/sink.go @@ -35,7 +35,6 @@ func NewSink(id uuid.UUID) *Sink { func (T *Sink) schedule(j job.Stalled) bool { if T.active == j.User { log.Printf("couldn't schedule because user %v is active", j.User) - panic("hmmmm") return false }