Skip to content

Commit 6d3a7ac

Browse files
authored
Merge pull request #77 from doringeman/defunct-runners
loader: trigger idle runner eviction immediately if a runner is defunct
2 parents 6cd0e61 + a4457f1 commit 6d3a7ac

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

pkg/inference/scheduling/loader.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -253,6 +253,12 @@ func (l *loader) idleCheckDuration() time.Duration {
253253
// Compute the oldest usage time for any idle runner.
254254
var oldest time.Time
255255
for _, slot := range l.runners {
256+
select {
257+
case <-l.slots[slot].done:
258+
// Check immediately if a runner is defunct
259+
return 0
260+
default:
261+
}
256262
if l.references[slot] == 0 {
257263
timestamp := l.timestamps[slot]
258264
if oldest.IsZero() || timestamp.Before(oldest) {

0 commit comments

Comments
 (0)