def _handle_message(self, name, uuid, args, kwargs, message={}):
        now_date = now()

        if "eta" in message:
            eta = self.parse_eta(message['eta'])

            if now() < eta:
                log.debug("greenqueue: task schedulet with eta [%s]", eta.isoformat())
                self.scheduler.push_task(eta, (name, uuid, args, kwargs))
                return

        self.work_queue.put((name, uuid, args, kwargs), block=True)
dataset/ETHPy150Open niwinz/django-greenqueue/greenqueue/worker/pgevent.py/GreenletManager._handle_message/original