Skip to content

Commit 0fba34f

Browse files
fixed async mode not working issue
1 parent 7fabd3b commit 0fba34f

3 files changed

Lines changed: 5 additions & 2 deletions

File tree

track/client.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
import atexit
12
import logging
23
import numbers
34

@@ -35,11 +36,13 @@ def __init__(self, write_key=None, host=None, debug=False,
3536
if sync_mode:
3637
self.consumer = None
3738
else:
39+
atexit.register(self.join)
3840
self.consumer = Consumer(
3941
queue=self.queue, write_key=write_key,
4042
host=host, on_error=on_error, retries=max_retries,
4143
timeout=timeout
4244
)
45+
self.consumer.start()
4346

4447
def identify(self, user_id=None, country_code='+91', phone_number=None, traits={}):
4548
"""Tie a user to their actions and record traits about them."""

track/request.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,5 +43,5 @@ def __init__(self, status, code, message):
4343
self.code = code
4444

4545
def __str__(self):
46-
msg = "[Segment] {0}: {1} ({2})"
46+
msg = "[interakt-track] {0}: {1} ({2})"
4747
return msg.format(self.code, self.message, self.status)

track/version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
VERSION = '0.0.4'
1+
VERSION = '0.0.5'

0 commit comments

Comments
 (0)