We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cb3e7ff commit 9adcdf3Copy full SHA for 9adcdf3
1 file changed
segment/analytics/consumer.py
@@ -14,9 +14,11 @@
14
# lower to leave space for extra data that will be added later, eg. "sentAt".
15
BATCH_SIZE_LIMIT = 475000
16
17
+
18
class FatalError(Exception):
19
def __init__(self, message):
20
self.message = message
21
22
def __str__(self):
23
msg = "[Segment] {0})"
24
return msg.format(self.message)
@@ -81,7 +83,7 @@ def upload(self):
81
83
# mark items as acknowledged from queue
82
84
for _ in batch:
85
self.queue.task_done()
- return success
86
+ return success
87
88
def next(self):
89
"""Return the next batch of items to upload."""
0 commit comments