def __init__(self):
    self.buff = {}
    self.pid = os.getpid()
    self.redis = redis.Redis.from_url(settings.BROKER_URL)
    for key in self.redis.keys('awx_callback_receiver_statistics_*'):
        self.redis.delete(key)
def __init__(self):
    self.buff = {}
    self.pid = os.getpid()
    self.redis = redis.Redis.from_url(settings.BROKER_URL)
    for key in self.redis.keys('awx_callback_receiver_statistics_*'):
        self.redis.delete(key)