|
@@ -250,6 +250,7 @@ func (s *Scheduler) processCompleted(ctx context.Context) {
|
|
defer runner.refMu.Unlock()
|
|
defer runner.refMu.Unlock()
|
|
if runner.expireTimer != nil {
|
|
if runner.expireTimer != nil {
|
|
runner.expireTimer.Stop()
|
|
runner.expireTimer.Stop()
|
|
|
|
+ runner.expireTimer = nil
|
|
}
|
|
}
|
|
s.expiredCh <- runner
|
|
s.expiredCh <- runner
|
|
})
|
|
})
|
|
@@ -430,6 +431,10 @@ type runnerRef struct {
|
|
|
|
|
|
// The refMu must already be held when calling unload
|
|
// The refMu must already be held when calling unload
|
|
func (runner *runnerRef) unload() {
|
|
func (runner *runnerRef) unload() {
|
|
|
|
+ if runner.expireTimer != nil {
|
|
|
|
+ runner.expireTimer.Stop()
|
|
|
|
+ runner.expireTimer = nil
|
|
|
|
+ }
|
|
if runner.llama != nil {
|
|
if runner.llama != nil {
|
|
runner.llama.Close()
|
|
runner.llama.Close()
|
|
}
|
|
}
|