

def tell_master(self, timeout, sigkill_on_stop):
    self.back_channel.put((self.queue, self.worker_num, timeout, sigkill_on_stop))

dataset/ETHPy150Open thread/django-lightweight-queue/django_lightweight_queue/worker.py Worker.tell_master/original