'Called for each job when the process assigned to it exits.'

def on_job_process_down(self, job, pid_gone):

    if (job._write_to and (not job._write_to._is_alive())):
        self.on_partial_read(job, job._write_to)
    elif (job._scheduled_for and (not job._scheduled_for._is_alive())):
        self._put_back(job)
