in cdsresponder/cds/cds_launcher.py [0:0]
def build_job_doc(self, job_name:str, cmd:list, labels:dict):
content_template = self.load_job_template()
if not isinstance(content_template, Job):
raise TypeError("cdsjob template must be for a Job, we got a {0}!".format(content_template.__class__.__name__))
content_template.metadata.name = self.sanitise_job_name(job_name)
content_template.spec.template.spec.containers[0].command = cmd
existing_labels = content_template.metadata.labels
if existing_labels is None:
existing_labels = {}
existing_labels.update(labels)
content_template.metadata.labels = existing_labels
return get_clean_dict(content_template)