def _get_expire(self, queue, argument):
        if isinstance(queue, basestring):
            doc = self.queues.find_one({'_id': queue})

            if not doc:
                return

            data = doc['options']
        else:
            data = queue

        try:
            value = data['arguments'][argument]
        except (KeyError, TypeError):
            return

        return self.get_now() + datetime.timedelta(milliseconds=value)
Property method that returns a bool specifying if the process is
dataset/ETHPy150Open celery/kombu/kombu/transport/mongodb.py/Channel._get_expire--crossover with--dataset/ETHPy150Open gmr/helper/helper/controller.py/Controller.is_sleeping