Skip to content

Commit

Permalink
chore: more leftover code need to be deleted (#117)
Browse files Browse the repository at this point in the history
  • Loading branch information
iandyh authored Aug 30, 2024
1 parent 0aaa1bd commit 9412f9a
Showing 1 changed file with 0 additions and 45 deletions.
45 changes: 0 additions & 45 deletions shibuya/controller/garbage.go
Original file line number Diff line number Diff line change
Expand Up @@ -116,9 +116,6 @@ func (c *Controller) AutoPurgeDeployments() {
log.Error(err)
continue
}
if config.SC.ExecutorConfig.Cluster.OnDemand {
c.autoPurgeNodes(deployedCollections)
}
for collectionID, launchTime := range deployedCollections {
collection, err := model.GetCollection(collectionID)
if err != nil {
Expand Down Expand Up @@ -236,45 +233,3 @@ func (c *Controller) AutoPurgeProjectIngressController() {
time.Sleep(gcInterval)
}
}

func (c *Controller) autoPurgeNodes(deployedCollections map[int64]time.Time) {
launchedNodes, err := c.Scheduler.GetAllNodesInfo()
if err != nil {
log.Error(err)
return
}
for id, nodeInfo := range launchedNodes {
collectionID, err := strconv.ParseInt(id, 10, 64)
if err != nil {
log.Error(err)
return
}
// if has pods deployed, don't touch
if _, ok := deployedCollections[collectionID]; ok {
return
}
collection, err := model.GetCollection(collectionID)
if err != nil {
log.Error(err)
return
}
lr, err := collection.GetLastRun()
if err != nil {
log.Error(err)
return
}
status, err := isCollectionStale(lr, nodeInfo.LaunchTime)
if err != nil {
log.Error(err)
return
}
if !status {
return
}
err = c.PurgeNodes(collection)
if err != nil {
log.Error(err)
return
}
}
}

0 comments on commit 9412f9a

Please sign in to comment.