[Cherry-pick for 1.11.3] (#260)

* Fix(actions): Fix Release build (#252) Signed-off-by: udit <[email protected]> * Adding probe image pull policy var for all the experiments (#253) * Adding probe image pull policy var for all the experiments Signed-off-by: ipsita2192 <[email protected]> * (refactor)status checks: add expected app/pod state to log (#258) Signed-off-by: ksatchit <[email protected]> * chore(cpu-cores): Adding cpu-cores in pod-cpu-hog experiments (#257) Signed-off-by: shubhamchaudhary <[email protected]> Co-authored-by: Udit Gaurav <[email protected]> * (enhance)httpProbe: add support for optional cert check disable (#259) * (enhance)httpProbe: add support for optional cert check disable Signed-off-by: ksatchit <[email protected]> * (chore)vendor: update vendor based on chaos operator changes Signed-off-by: ksatchit <[email protected]> Co-authored-by: Udit Gaurav <[email protected]> Co-authored-by: SamarSidharth <[email protected]> Co-authored-by: Shubham Chaudhary <[email protected]>
litmuschaos · Jan 8, 2021 · e9ea060 · e9ea060
1 parent bc2a024
commit e9ea060
Show file tree

Hide file tree

Showing 47 changed files with 341 additions and 255 deletions.
diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml
@@ -3,7 +3,7 @@ name: Release
 on:
   create:
     tags:
-      - 'v*'
+      - '**'
 
 jobs:
   lint:
@@ -55,7 +55,7 @@ jobs:
 
       - name: Set Tag
         run: |
-          TAG="${GITHUB_REF#refs/*/v}"
+          TAG="${GITHUB_REF#refs/*/}"
           echo "TAG=${TAG}" >> $GITHUB_ENV
           echo "RELEASE_TAG=${TAG}" >> $GITHUB_ENV
 

diff --git a/chaoslib/litmus/pod-cpu-hog/lib/pod-cpu-hog.go b/chaoslib/litmus/pod-cpu-hog/lib/pod-cpu-hog.go
@@ -24,15 +24,16 @@ import (
 // StressCPU Uses the REST API to exec into the target container of the target pod
 // The function will be constantly increasing the CPU utilisation until it reaches the maximum available or allowed number.
 // Using the TOTAL_CHAOS_DURATION we will need to specify for how long this experiment will last
-func StressCPU(containerName, podName, namespace, cpuHogCmd string, clients clients.ClientSets) error {
+func StressCPU(experimentsDetails *experimentTypes.ExperimentDetails, podName string, clients clients.ClientSets) error {
 	// It will contains all the pod & container details required for exec command
 	execCommandDetails := litmusexec.PodDetails{}
-	command := []string{"/bin/sh", "-c", cpuHogCmd}
-	litmusexec.SetExecCommandAttributes(&execCommandDetails, podName, containerName, namespace)
+	command := []string{"/bin/sh", "-c", experimentsDetails.ChaosInjectCmd}
+	litmusexec.SetExecCommandAttributes(&execCommandDetails, podName, experimentsDetails.TargetContainer, experimentsDetails.AppNS)
 	_, err := litmusexec.Exec(&execCommandDetails, clients, command)
 	if err != nil {
 		return errors.Errorf("Unable to run stress command inside target container, err: %v", err)
 	}
+
 	return nil
 }
 
@@ -85,7 +86,9 @@ func InjectChaosInSerialMode(experimentsDetails *experimentTypes.ExperimentDetai
 			"Pod":       pod.Name,
 			"CPU CORE":  experimentsDetails.CPUcores,
 		})
-		go StressCPU(experimentsDetails.TargetContainer, pod.Name, experimentsDetails.AppNS, experimentsDetails.ChaosInjectCmd, clients)
+		for i := 0; i < experimentsDetails.CPUcores; i++ {
+			go StressCPU(experimentsDetails, pod.Name, clients)
+		}
 
 		log.Infof("[Chaos]:Waiting for: %vs", experimentsDetails.ChaosDuration)
 
@@ -99,7 +102,7 @@ func InjectChaosInSerialMode(experimentsDetails *experimentTypes.ExperimentDetai
 			select {
 			case <-signChan:
 				log.Info("[Chaos]: Killing process started because of terminated signal received")
-				err := KillStressCPUSerial(experimentsDetails.TargetContainer, pod.Name, experimentsDetails.AppNS, experimentsDetails.ChaosKillCmd, clients)
+				err := KillStressCPUSerial(experimentsDetails, pod.Name, clients)
 				if err != nil {
 					klog.V(0).Infof("Error in Kill stress after abortion")
 					return err
@@ -124,7 +127,7 @@ func InjectChaosInSerialMode(experimentsDetails *experimentTypes.ExperimentDetai
 				break loop
 			}
 		}
-		if err := KillStressCPUSerial(experimentsDetails.TargetContainer, pod.Name, experimentsDetails.AppNS, experimentsDetails.ChaosKillCmd, clients); err != nil {
+		if err := KillStressCPUSerial(experimentsDetails, pod.Name, clients); err != nil {
 			return err
 		}
 	}
@@ -150,7 +153,9 @@ func InjectChaosInParallelMode(experimentsDetails *experimentTypes.ExperimentDet
 			"CPU CORE":  experimentsDetails.CPUcores,
 		})
 
-		go StressCPU(experimentsDetails.TargetContainer, pod.Name, experimentsDetails.AppNS, experimentsDetails.ChaosInjectCmd, clients)
+		for i := 0; i < experimentsDetails.CPUcores; i++ {
+			go StressCPU(experimentsDetails, pod.Name, clients)
+		}
 	}
 
 	log.Infof("[Chaos]:Waiting for: %vs", experimentsDetails.ChaosDuration)
@@ -165,7 +170,7 @@ loop:
 		select {
 		case <-signChan:
 			log.Info("[Chaos]: Killing process started because of terminated signal received")
-			err := KillStressCPUParallel(experimentsDetails.TargetContainer, targetPodList, experimentsDetails.AppNS, experimentsDetails.ChaosKillCmd, clients)
+			err := KillStressCPUParallel(experimentsDetails, targetPodList, clients)
 			if err != nil {
 				klog.V(0).Infof("Error in Kill stress after abortion")
 				return err
@@ -190,7 +195,7 @@ loop:
 			break loop
 		}
 	}
-	if err := KillStressCPUParallel(experimentsDetails.TargetContainer, targetPodList, experimentsDetails.AppNS, experimentsDetails.ChaosKillCmd, clients); err != nil {
+	if err := KillStressCPUParallel(experimentsDetails, targetPodList, clients); err != nil {
 		return err
 	}
 
@@ -231,13 +236,13 @@ func GetTargetContainer(experimentsDetails *experimentTypes.ExperimentDetails, a
 
 // KillStressCPUSerial function to kill a stress process running inside target container
 //  Triggered by either timeout of chaos duration or termination of the experiment
-func KillStressCPUSerial(containerName, podName, namespace, cpuFreeCmd string, clients clients.ClientSets) error {
+func KillStressCPUSerial(experimentsDetails *experimentTypes.ExperimentDetails, podName string, clients clients.ClientSets) error {
 	// It will contains all the pod & container details required for exec command
 	execCommandDetails := litmusexec.PodDetails{}
 
-	command := []string{"/bin/sh", "-c", cpuFreeCmd}
+	command := []string{"/bin/sh", "-c", experimentsDetails.ChaosKillCmd}
 
-	litmusexec.SetExecCommandAttributes(&execCommandDetails, podName, containerName, namespace)
+	litmusexec.SetExecCommandAttributes(&execCommandDetails, podName, experimentsDetails.TargetContainer, experimentsDetails.AppNS)
 	_, err := litmusexec.Exec(&execCommandDetails, clients, command)
 	if err != nil {
 		return errors.Errorf("Unable to kill the stress process in %v pod, err: %v", podName, err)
@@ -248,11 +253,11 @@ func KillStressCPUSerial(containerName, podName, namespace, cpuFreeCmd string, c
 
 // KillStressCPUParallel function to kill all the stress process running inside target container
 // Triggered by either timeout of chaos duration or termination of the experiment
-func KillStressCPUParallel(containerName string, targetPodList corev1.PodList, namespace, cpuFreeCmd string, clients clients.ClientSets) error {
+func KillStressCPUParallel(experimentsDetails *experimentTypes.ExperimentDetails, targetPodList corev1.PodList, clients clients.ClientSets) error {
 
 	for _, pod := range targetPodList.Items {
 
-		if err := KillStressCPUSerial(containerName, pod.Name, namespace, cpuFreeCmd, clients); err != nil {
+		if err := KillStressCPUSerial(experimentsDetails, pod.Name, clients); err != nil {
 			return err
 		}
 	}

diff --git a/go.mod b/go.mod
@@ -12,7 +12,7 @@ require (
 	github.com/imdario/mergo v0.3.9 // indirect
 	github.com/kr/pretty v0.2.0 // indirect
 	github.com/kyokomi/emoji v2.2.4+incompatible
-	github.com/litmuschaos/chaos-operator v0.0.0-20201210172142-57fddee6734e
+	github.com/litmuschaos/chaos-operator v0.0.0-20210108143008-188ee98457c8
 	github.com/mailru/easyjson v0.7.1 // indirect
 	github.com/openebs/maya v0.0.0-20200411140727-1c81f9e017b0
 	github.com/pkg/errors v0.9.1

diff --git a/go.sum b/go.sum
@@ -476,6 +476,8 @@ github.com/liggitt/tabwriter v0.0.0-20181228230101-89fcab3d43de/go.mod h1:zAbeS9
 github.com/lithammer/dedent v1.1.0/go.mod h1:jrXYCQtgg0nJiN+StA2KgR7w6CiQNv9Fd/Z9BP0jIOc=
 github.com/litmuschaos/chaos-operator v0.0.0-20201210172142-57fddee6734e h1:ubIPSIWT4le0PZZ4MrALdgkiIVmGrz0YzYeWWvSC2a4=
 github.com/litmuschaos/chaos-operator v0.0.0-20201210172142-57fddee6734e/go.mod h1:Z2GpYjqXwFd8bx+kv58YEQFxynx1v9PMGCGTQFRVnFQ=
+github.com/litmuschaos/chaos-operator v0.0.0-20210108143008-188ee98457c8 h1:aEpAyowpCm1lgMoWLcO4Han0yp2WvLuRzKHVKxjvJr0=
+github.com/litmuschaos/chaos-operator v0.0.0-20210108143008-188ee98457c8/go.mod h1:Z2GpYjqXwFd8bx+kv58YEQFxynx1v9PMGCGTQFRVnFQ=
 github.com/litmuschaos/elves v0.0.0-20201107015738-552d74669e3c/go.mod h1:DsbHGNUq/78NZozWVVI9Q6eBei4I+JjlkkD5aibJ3MQ=
 github.com/lpabon/godbc v0.1.1/go.mod h1:Jo9QV0cf3U6jZABgiJ2skINAXb9j8m51r07g4KI92ZA=
 github.com/lucas-clemente/aes12 v0.0.0-20171027163421-cd47fb39b79f h1:sSeNEkJrs+0F9TUau0CgWTTNEwF23HST3Eq0A+QIx+A=

diff --git a/pkg/cassandra/pod-delete/environment/environment.go b/pkg/cassandra/pod-delete/environment/environment.go
@@ -71,4 +71,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, cassandraDetails
 	chaosDetails.Timeout = cassandraDetails.ChaoslibDetail.Timeout
 	chaosDetails.Delay = cassandraDetails.ChaoslibDetail.Delay
 	chaosDetails.AppDetail = appDetails
+	chaosDetails.ProbeImagePullPolicy = cassandraDetails.ChaoslibDetail.LIBImagePullPolicy
 }
diff --git a/pkg/generic/disk-fill/environment/environment.go b/pkg/generic/disk-fill/environment/environment.go
@@ -66,4 +66,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.AppDetail = appDetails
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/kubelet-service-kill/environment/environment.go b/pkg/generic/kubelet-service-kill/environment/environment.go
@@ -53,4 +53,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/network-chaos/environment/environment.go b/pkg/generic/network-chaos/environment/environment.go
@@ -75,4 +75,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.ChaosDuration = experimentDetails.ChaosDuration
 	chaosDetails.AppDetail = appDetails
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/network-latency/environment/environment.go b/pkg/generic/network-latency/environment/environment.go
@@ -104,4 +104,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.InstanceID = experimentDetails.InstanceID
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/network-latency/types/types.go b/pkg/generic/network-latency/types/types.go
@@ -7,26 +7,27 @@ import (
 
 // ExperimentDetails is for collecting all the experiment-related details
 type ExperimentDetails struct {
-	ExperimentName      string
-	EngineName          string
-	ChaosDuration       int
-	ChaosInterval       int
-	RampTime            int
-	ChaosLib            string
-	ChaosServiceAccount string
-	AppNS               string
-	AppLabel            string
-	AppKind             string
-	ChaosUID            clientTypes.UID
-	AuxiliaryAppInfo    string
-	InstanceID          string
-	ChaosNamespace      string
-	ChaosPodName        string
-	Latency             float64
-	Jitter              float64
-	ChaosNode           string
-	Timeout             int
-	Delay               int
+	ExperimentName        string
+	EngineName            string
+	ChaosDuration         int
+	ChaosInterval         int
+	RampTime              int
+	ChaosLib              string
+	ChaosServiceAccount   string
+	AppNS                 string
+	AppLabel              string
+	AppKind               string
+	ChaosUID              clientTypes.UID
+	AuxiliaryAppInfo      string
+	InstanceID            string
+	ChaosNamespace        string
+	ChaosPodName          string
+	Latency               float64
+	Jitter                float64
+	ChaosNode             string
+	Timeout               int
+	Delay                 int
+	LIBImagePullPolicy    string
 }
 
 // Definition is the chaos experiment definition coming from a user input file.

diff --git a/pkg/generic/node-cpu-hog/environment/environment.go b/pkg/generic/node-cpu-hog/environment/environment.go
@@ -55,4 +55,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/node-drain/environment/environment.go b/pkg/generic/node-drain/environment/environment.go
@@ -51,4 +51,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.InstanceID = experimentDetails.InstanceID
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/node-drain/types/types.go b/pkg/generic/node-drain/types/types.go
@@ -6,20 +6,21 @@ import (
 
 // ExperimentDetails is for collecting all the experiment-related details
 type ExperimentDetails struct {
-	ExperimentName   string
-	EngineName       string
-	ChaosDuration    int
-	RampTime         int
-	ChaosLib         string
-	AppNS            string
-	AppLabel         string
-	AppKind          string
-	ChaosUID         clientTypes.UID
-	InstanceID       string
-	ChaosNamespace   string
-	ChaosPodName     string
-	TargetNode       string
-	AuxiliaryAppInfo string
-	Timeout          int
-	Delay            int
+	ExperimentName     string
+	EngineName         string
+	ChaosDuration      int
+	RampTime           int
+	ChaosLib           string
+	AppNS              string
+	AppLabel           string
+	AppKind            string
+	ChaosUID           clientTypes.UID
+	InstanceID         string
+	ChaosNamespace     string
+	ChaosPodName       string
+	TargetNode         string
+	AuxiliaryAppInfo   string
+	Timeout            int
+	Delay              int
+	LIBImagePullPolicy string
 }
diff --git a/pkg/generic/node-io-stress/environment/environment.go b/pkg/generic/node-io-stress/environment/environment.go
@@ -57,4 +57,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/node-memory-hog/environment/environment.go b/pkg/generic/node-memory-hog/environment/environment.go
@@ -55,4 +55,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/node-restart/environment/environment.go b/pkg/generic/node-restart/environment/environment.go
@@ -55,4 +55,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/node-taint/environment/environment.go b/pkg/generic/node-taint/environment/environment.go
@@ -52,4 +52,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.InstanceID = experimentDetails.InstanceID
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/node-taint/types/types.go b/pkg/generic/node-taint/types/types.go
@@ -6,21 +6,22 @@ import (
 
 // ExperimentDetails is for collecting all the experiment-related details
 type ExperimentDetails struct {
-	ExperimentName   string
-	EngineName       string
-	RampTime         int
-	ChaosDuration    int
-	ChaosLib         string
-	AppNS            string
-	AppLabel         string
-	AppKind          string
-	ChaosUID         clientTypes.UID
-	InstanceID       string
-	ChaosNamespace   string
-	ChaosPodName     string
-	TargetNode       string
-	AuxiliaryAppInfo string
-	Taints           string
-	Timeout          int
-	Delay            int
+	ExperimentName     string
+	EngineName         string
+	RampTime           int
+	ChaosDuration      int
+	ChaosLib           string
+	AppNS              string
+	AppLabel           string
+	AppKind            string
+	ChaosUID           clientTypes.UID
+	InstanceID         string
+	ChaosNamespace     string
+	ChaosPodName       string
+	TargetNode         string
+	AuxiliaryAppInfo   string
+	Taints             string
+	Timeout            int
+	Delay              int
+	LIBImagePullPolicy string
 }
diff --git a/pkg/generic/pod-autoscaler/environment/environment.go b/pkg/generic/pod-autoscaler/environment/environment.go
@@ -48,5 +48,6 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.EngineName = experimentDetails.EngineName
 	chaosDetails.ExperimentName = experimentDetails.ExperimentName
 	chaosDetails.InstanceID = experimentDetails.InstanceID
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 
 }
diff --git a/pkg/generic/pod-autoscaler/types/types.go b/pkg/generic/pod-autoscaler/types/types.go
@@ -24,6 +24,7 @@ type ExperimentDetails struct {
 	AuxiliaryAppInfo    string
 	Timeout             int
 	Delay               int
+	LIBImagePullPolicy  string
 }
 
 // ApplicationUnderTest contains the name of the deployment object and the current replica count

diff --git a/pkg/generic/pod-cpu-hog/environment/environment.go b/pkg/generic/pod-cpu-hog/environment/environment.go
@@ -30,7 +30,7 @@ func GetENV(experimentDetails *experimentTypes.ExperimentDetails) {
 	experimentDetails.Timeout, _ = strconv.Atoi(Getenv("STATUS_CHECK_TIMEOUT", "180"))
 	experimentDetails.TargetPods = Getenv("TARGET_PODS", "")
 	experimentDetails.ChaosInjectCmd = Getenv("CHAOS_INJECT_COMMAND", "md5sum /dev/zero")
-	experimentDetails.ChaosKillCmd = Getenv("CHAOS_KILL_COMMAND", "kill $(find /proc -name exe -lname '*/md5sum' 2>&1 | grep -v 'Permission denied' | awk -F/ '{print $(NF-1)}' |  head -n 1)")
+	experimentDetails.ChaosKillCmd = Getenv("CHAOS_KILL_COMMAND", "kill $(find /proc -name exe -lname '*/md5sum' 2>&1 | grep -v 'Permission denied' | awk -F/ '{print $(NF-1)}')")
 	experimentDetails.LIBImage = Getenv("LIB_IMAGE", "gaiaadm/pumba")
 	experimentDetails.LIBImagePullPolicy = Getenv("LIB_IMAGE_PULL_POLICY", "Always")
 	experimentDetails.TargetContainer = Getenv("TARGET_CONTAINER", "")
@@ -67,4 +67,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.AppDetail = appDetails
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/pod-delete/environment/environment.go b/pkg/generic/pod-delete/environment/environment.go
@@ -62,4 +62,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.AppDetail = appDetails
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/pod-delete/types/types.go b/pkg/generic/pod-delete/types/types.go
@@ -27,4 +27,5 @@ type ExperimentDetails struct {
 	TargetPods          string
 	PodsAffectedPerc    int
 	Sequence            string
+	LIBImagePullPolicy  string
 }
diff --git a/pkg/generic/pod-io-stress/environment/environment.go b/pkg/generic/pod-io-stress/environment/environment.go
@@ -67,4 +67,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.AppDetail = appDetails
 	chaosDetails.JobCleanupPolicy = Getenv("JOB_CLEANUP_POLICY", "retain")
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/generic/pod-memory-hog/environment/environment.go b/pkg/generic/pod-memory-hog/environment/environment.go
@@ -65,4 +65,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, experimentDetail
 	chaosDetails.Timeout = experimentDetails.Timeout
 	chaosDetails.Delay = experimentDetails.Delay
 	chaosDetails.AppDetail = appDetails
+	chaosDetails.ProbeImagePullPolicy = experimentDetails.LIBImagePullPolicy
 }
diff --git a/pkg/kafka/environment/environment.go b/pkg/kafka/environment/environment.go
@@ -82,4 +82,5 @@ func InitialiseChaosVariables(chaosDetails *types.ChaosDetails, kafkaDetails *ka
 	chaosDetails.Timeout = kafkaDetails.ChaoslibDetail.Timeout
 	chaosDetails.Delay = kafkaDetails.ChaoslibDetail.Delay
 	chaosDetails.AppDetail = appDetails
+	chaosDetails.ProbeImagePullPolicy = kafkaDetails.ChaoslibDetail.LIBImagePullPolicy
 }