analytics: fix misspelled class name
This commit is contained in:
parent
12b458780b
commit
47675b88f5
1 changed files with 3 additions and 3 deletions
|
@ -9,12 +9,12 @@ from mixpanel import BufferedConsumer, Mixpanel
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
class MixpanelQueingConsumer(object):
|
class MixpanelQueuingConsumer(object):
|
||||||
def __init__(self, request_queue):
|
def __init__(self, request_queue):
|
||||||
self._mp_queue = request_queue
|
self._mp_queue = request_queue
|
||||||
|
|
||||||
def send(self, endpoint, json_message):
|
def send(self, endpoint, json_message):
|
||||||
logger.debug('Queing mixpanel request.')
|
logger.debug('Queuing mixpanel request.')
|
||||||
self._mp_queue.put(json.dumps([endpoint, json_message]))
|
self._mp_queue.put(json.dumps([endpoint, json_message]))
|
||||||
|
|
||||||
|
|
||||||
|
@ -59,7 +59,7 @@ class Analytics(object):
|
||||||
app.config['MIXPANEL_KEY'])
|
app.config['MIXPANEL_KEY'])
|
||||||
|
|
||||||
request_queue = Queue()
|
request_queue = Queue()
|
||||||
analytics = Mixpanel(mixpanel_key, MixpanelQueingConsumer(request_queue))
|
analytics = Mixpanel(mixpanel_key, MixpanelQueuingConsumer(request_queue))
|
||||||
SendToMixpanel(request_queue).start()
|
SendToMixpanel(request_queue).start()
|
||||||
|
|
||||||
else:
|
else:
|
||||||
|
|
Reference in a new issue