

def idle_time_reached(self, time_item_last_processed):
    idle_time = (datetime.datetime.utcnow() - time_item_last_processed)
    return (idle_time > datetime.timedelta(minutes=30))

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