Default to runner param in k8s if destination param is undefined

lib/galaxy/jobs/runners/kubernetes.py

@@ -267,8 +267,10 @@ def __configure_port_routing(self, ajs):
         ingress.create()
 
     def __get_overridable_params(self, job_wrapper, param_key):
-        dest_params = self.__get_destination_param(job_wrapper, param_key)
-        return dest_params.get(param_key, self.runner_params[param_key])
+        try:
+            return job_wrapper.job_destination.params[param_key]
+        except KeyError:
+            self.runner_params[param_key]
 
     def __get_pull_policy(self):
         return pull_policy(self.runner_params)
@@ -710,13 +712,6 @@ def __get_k8s_container_name(self, job_wrapper):
     def __get_k8s_job_name(self, prefix, job_wrapper):
         return f"{prefix}-{self.__force_label_conformity(job_wrapper.get_id_tag())}"
 
-    def __get_destination_param(self, job_wrapper, param_key):
-        """Obtains allowable runner param overrides from the destination"""
-        try:
-            return job_wrapper.job_destination.params[param_key]
-        except KeyError:
-            return None
-
     def check_watched_item(self, job_state):
         """Checks the state of a job already submitted on k8s. Job state is an AsynchronousJobState"""
         jobs = find_job_object_by_name(self._pykube_api, job_state.job_id, self.runner_params["k8s_namespace"])