def check_job()

in cdsreaper/jobwatcher.py [0:0]

• 13 lines of code
• 3 McCabe index (conditional complexity)

    def check_job(self, j:V1Job):
        status = self.get_job_status_string(j)
        logger.info("Job {0} ({1}) is in status {2}".format(j.metadata.name, j.metadata.uid, status))
        routing_key = "cds.job.{0}".format(status)
        message_body = {
            "job-id": j.metadata.uid,
            "job-name": j.metadata.name,
            "job-namespace": j.metadata.namespace,
            "retry-count": j.status.failed if j.status.failed is not None else 0
        }

        if status=="failed":
            message_body["failure-reason"] = JobWatcher.get_job_failure_reason(j.status)

        return self._sender.notify(routing_key, message_body)