'Create job script and submit it to Kubernetes cluster'

def queue_job(self, job_wrapper):

    log.debug(('Starting    queue_job    for    job    ' + job_wrapper.get_id_tag()))
    if (not self.prepare_job(job_wrapper, include_metadata=False, modify_command_for_container=False)):
        return
    job_destination = job_wrapper.job_destination
    k8s_job_name = self.__produce_unique_k8s_job_name(job_wrapper.get_id_tag())
    k8s_job_obj = {'apiVersion': self.runner_params['k8s_job_api_version'], 'kind': 'Job', 'metadata': {'name': k8s_job_name, 'namespace': 'default', 'labels': {'app': k8s_job_name}}, 'spec': self.__get_k8s_job_spec(job_wrapper)}
    job = Job(self._pykube_api, k8s_job_obj)
    if job.exists():
        job.delete()
    Job(self._pykube_api, k8s_job_obj).create()
    ajs = AsynchronousJobState(files_dir=job_wrapper.working_directory, job_wrapper=job_wrapper, job_id=k8s_job_name, job_destination=job_destination)
    self.monitor_queue.put(ajs)
    external_runjob_script = None
    return external_runjob_script
