def test_monitor_queue_size(self, celery, redis, stats):
    data = {'export_queue_internal': 3, 'export_queue_backup:abcd-ef-1234': 7}
    for name in celery.all_queues:
        data[name] = randint(1, 10)
    for (k, v) in data.items():
        redis.lpush(k, *range(v))
    monitor_queue_size.delay().get()
    stats.check(gauge=[('queue', 1, v, [('queue:' + k)]) for (k, v) in data.items()])
def test_monitor_queue_size(self, celery, redis, stats):
    data = {'export_queue_internal': 3, 'export_queue_backup:abcd-ef-1234': 7}
    for name in celery.all_queues:
        data[name] = randint(1, 10)
    for (k, v) in data.items():
        redis.lpush(k, *range(v))
    monitor_queue_size.delay().get()
    stats.check(gauge=[('queue', 1, v, [('queue:' + k)]) for (k, v) in data.items()])