Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion segment/analytics/consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,9 +14,11 @@
# lower to leave space for extra data that will be added later, eg. "sentAt".
BATCH_SIZE_LIMIT = 475000


class FatalError(Exception):
def __init__(self, message):
self.message = message

def __str__(self):
msg = "[Segment] {0})"
return msg.format(self.message)
Expand Down Expand Up @@ -81,7 +83,7 @@ def upload(self):
# mark items as acknowledged from queue
for _ in batch:
self.queue.task_done()
return success
return success

def next(self):
"""Return the next batch of items to upload."""
Expand Down
Loading