diff --git a/pkg/model/process.go b/pkg/model/process.go index 62a3f7faf..cbf016acf 100644 --- a/pkg/model/process.go +++ b/pkg/model/process.go @@ -24,8 +24,6 @@ func (ml *ModelLoader) deleteProcess(s string) error { return fmt.Errorf("model %s not found", s) } - defer delete(ml.models, s) - retries := 1 for model.GRPC(false, ml.wd).IsBusy() { xlog.Debug("Model busy. Waiting.", "model", s) @@ -48,6 +46,7 @@ func (ml *ModelLoader) deleteProcess(s string) error { if process == nil { xlog.Error("No process", "model", s) // Nothing to do as there is no process + delete(ml.models, s) return nil } @@ -56,6 +55,10 @@ func (ml *ModelLoader) deleteProcess(s string) error { xlog.Error("(deleteProcess) error while deleting process", "error", err, "model", s) } + if err == nil { + delete(ml.models, s) + } + return err }