Skip to content

Commit

Permalink
remove restart worker logic as it will taken care worker monitor
Browse files Browse the repository at this point in the history
  • Loading branch information
rasamala83 committed Dec 18, 2024
1 parent 1b84a6b commit 0ad258d
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions lib/workerclient.go
Original file line number Diff line number Diff line change
Expand Up @@ -701,10 +701,6 @@ func (worker *WorkerClient) Recover(p *WorkerPool, ticket string, recovParam Wor
if logger.GetLogger().V(logger.Debug) {
logger.GetLogger().Log(logger.Debug, fmt.Sprintf("worker Id: %d and process: %d recovered as part of workerRecoverTimeout set status to INIT", worker.ID, worker.pid))
}
err := p.RestartWorker(worker)
if err != nil {
logger.GetLogger().Log(logger.Alert, fmt.Sprintf("worker: %d failed to restart worker process", worker.ID))
}
return
case msg, ok := <-worker.channel():
if !ok {
Expand Down

0 comments on commit 0ad258d

Please sign in to comment.