in cdsresponder/cds/cds_launcher.py [0:0]
def launch_cds_job(self, inmeta_path: str, job_name: str, route_name: str, labels:dict) -> kubernetes.client.models.V1Job:
command_parts = [
"/usr/local/bin/cds_run.pl",
"--input-inmeta",
inmeta_path,
"--route",
route_name
]
jobdoc = self.build_job_doc(job_name, command_parts, labels)
logger.debug("Built job doc for submission: {0}".format(jobdoc))
return self.batch.create_namespaced_job(
body=jobdoc,
namespace=self.namespace
)