|
@@ -536,7 +536,7 @@ class Repository:
|
|
self.prepare_txn(index_transaction_id, do_cleanup=False)
|
|
self.prepare_txn(index_transaction_id, do_cleanup=False)
|
|
try:
|
|
try:
|
|
segment_count = sum(1 for _ in self.io.segment_iterator())
|
|
segment_count = sum(1 for _ in self.io.segment_iterator())
|
|
- pi = ProgressIndicatorPercent(total=segment_count, msg="Replaying segments %3.0f%%", same_line=True)
|
|
|
|
|
|
+ pi = ProgressIndicatorPercent(total=segment_count, msg="Replaying segments %3.0f%%")
|
|
for i, (segment, filename) in enumerate(self.io.segment_iterator()):
|
|
for i, (segment, filename) in enumerate(self.io.segment_iterator()):
|
|
pi.show(i)
|
|
pi.show(i)
|
|
if index_transaction_id is not None and segment <= index_transaction_id:
|
|
if index_transaction_id is not None and segment <= index_transaction_id:
|
|
@@ -636,7 +636,7 @@ class Repository:
|
|
segments_transaction_id = self.io.get_segments_transaction_id()
|
|
segments_transaction_id = self.io.get_segments_transaction_id()
|
|
self.prepare_txn(None) # self.index, self.compact, self.segments all empty now!
|
|
self.prepare_txn(None) # self.index, self.compact, self.segments all empty now!
|
|
segment_count = sum(1 for _ in self.io.segment_iterator())
|
|
segment_count = sum(1 for _ in self.io.segment_iterator())
|
|
- pi = ProgressIndicatorPercent(total=segment_count, msg="Checking segments %3.1f%%", step=0.1, same_line=True)
|
|
|
|
|
|
+ pi = ProgressIndicatorPercent(total=segment_count, msg="Checking segments %3.1f%%", step=0.1)
|
|
for i, (segment, filename) in enumerate(self.io.segment_iterator()):
|
|
for i, (segment, filename) in enumerate(self.io.segment_iterator()):
|
|
pi.show(i)
|
|
pi.show(i)
|
|
if segment > transaction_id:
|
|
if segment > transaction_id:
|