def get(self):
        queue_key = '{}:queue'.format(self.prefix)
        min_s = 0
        max_s = time() - (self.delay / 1000)

        results = self.conn.zrangebyscore(queue_key, min_s, max_s, 0, 1)
        if not results:
            return None

        key = results[0]
        pipe = self.conn.pipeline()
        pipe.hgetall(key)
        pipe.delete(key)
        pipe.zrem(queue_key, key)
        data = pipe.execute()[0]
        data['config'] = json.loads(data['config'])
        data['event'] = int(data['event'])
        return data
With the C{savestats} option specified, L{app.ProfileRunner.run}
dataset/ETHPy150Open getsentry/freight/freight/notifiers/queue.py/NotificationQueue.get--crossover with--dataset/ETHPy150Open kuri65536/python-for-android/python-modules/twisted/twisted/test/test_twistd.py/AppProfilingTestCase.test_profileSaveStats