feat: Add image pull policy when create KEDA connector deployments (#1944)

Co-authored-by: Vishal <vishal-biyani@users.noreply.github.com>

charts/fission-all/templates/deployment.yaml

@@ -1095,6 +1095,8 @@ spec:
           value: {{ .Values.traceSamplingRate | default "0.5" | quote }}
         - name: DEBUG_ENV
           value: {{ .Values.debugEnv | quote }}
+        - name: CONNECTOR_IMAGE_PULL_POLICY
+          value: "{{ .Values.pullPolicy }}"
         - name: KAFKA_IMAGE
           value: "{{ .Values.mqt_keda.connector_images.kafka.image }}:{{ .Values.mqt_keda.connector_images.kafka.tag }}"
         - name: RABBITMQ_IMAGE

charts/fission-core/templates/deployment.yaml

@@ -484,6 +484,8 @@ spec:
           value: {{ .Values.traceSamplingRate | default "0.5" | quote }}
         - name: DEBUG_ENV
           value: {{ .Values.debugEnv | quote }}
+        - name: CONNECTOR_IMAGE_PULL_POLICY
+          value: "{{ .Values.pullPolicy }}"
         - name: KAFKA_IMAGE
           value: "{{ .Values.mqt_keda.connector_images.kafka.image }}:{{ .Values.mqt_keda.connector_images.kafka.tag }}"
         - name: RABBITMQ_IMAGE

pkg/mqtrigger/scalermanager.go

@@ -393,6 +393,7 @@ func getDeploymentSpec(mqt *fv1.MessageQueueTrigger, routerURL string, kubeClien
 	}
 	imageName := fmt.Sprintf("%s_image", string(mqt.Spec.MessageQueueType))
 	image := os.Getenv(strings.ToUpper(imageName))
+	imagePullPolicy := utils.GetImagePullPolicy(os.Getenv("CONNECTOR_IMAGE_PULL_POLICY"))
 
 	blockOwnerDeletion := true
 	return &appsv1.Deployment{
@@ -428,7 +429,7 @@ func getDeploymentSpec(mqt *fv1.MessageQueueTrigger, routerURL string, kubeClien
 						{
 							Name:            mqt.ObjectMeta.Name,
 							Image:           image,
-							ImagePullPolicy: "Always",
+							ImagePullPolicy: imagePullPolicy,
 							Env:             envVars,
 						},
 					},