fix: disabling zombiecheck for k8s

2023-10-19 22:56:55 +05:30
parent 81a06e3de5
commit 225efcc190
1 changed files with 3 additions and 1 deletions
@@ -1554,8 +1554,10 @@ func getRunningWorkers(ctx context.Context, workerTimeout int) int {
 // FIXME - add this to remove exited workers
 // Should it check what happened to the execution? idk
 func zombiecheck(ctx context.Context, workerTimeout int) error {
+	isK8s := os.Getenv("IS_KUBERNETES") == "true"
+
 	executionIds = []string{}
-	if swarmConfig == "run" || swarmConfig == "swarm" {
+	if swarmConfig == "run" || swarmConfig == "swarm" || isK8s {
 		//log.Printf("[DEBUG] Skipping Zombie check due to new execution model (swarm)")
 		return nil
 	}