'Called when a job was partially written to exited child.'

def on_partial_read(self, job, proc):

    if (not job._accepted):
        self._put_back(job)
    writer = _get_job_writer(job)
    if writer:
        self._active_writers.discard(writer)
        del writer
    if (not proc.dead):
        proc.dead = True
        before = len(self._queues)
        try:
            queues = self._find_worker_queues(proc)
            if self.destroy_queues(queues, proc):
                self._queues[self.create_process_queues()] = None
        except ValueError:
            pass
        assert (len(self._queues) == before)
