def METHOD_NAME(self, job):
    self.log.warning(
        "Job %s exceeded timeout of %ds (+%ds grace period) but work horse did not terminate it. "
        "Killing the work horse.",
        job.id,
        job.timeout,
        self.grace_period,
    )
    self.kill_horse()