def METHOD_NAME(self):
    with self._status_lock:
        if not RunStatus.is_terminated(self._status):
            _logger.info("Cancelling job.")
            self._kube_api.delete_namespaced_job(
                name=self._job_name,
                namespace=self._job_namespace,
                body=kubernetes.client.V1DeleteOptions(),
                pretty=True,
            )
            self._status = RunStatus.KILLED
            _logger.info("Job cancelled.")
        else:
            _logger.info("Attempting to cancel a job that is already terminated.")