From 0ad258d7b8d82f98f7ca9688e1f9fb33e4d20996 Mon Sep 17 00:00:00 2001 From: Rajesh Samala Date: Wed, 18 Dec 2024 21:59:54 +0530 Subject: [PATCH] remove restart worker logic as it will taken care worker monitor --- lib/workerclient.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/lib/workerclient.go b/lib/workerclient.go index 623bf4a..e1788bb 100644 --- a/lib/workerclient.go +++ b/lib/workerclient.go @@ -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 {