buckets, start_slice)
self.last_complete_prefix_index = i
self.save_state()
- if time.time() > start_slice + self.cpu_slice:
+ if time.time() >= start_slice + self.cpu_slice:
raise TimeSliceExceeded()
# yay! we finished the whole cycle
self.last_complete_prefix_index = -1
# time-consuming, but lets us avoid losing more than one bucket's
# worth of progress.
self.save_state()
- if time.time() > start_slice + self.cpu_slice:
+ if time.time() >= start_slice + self.cpu_slice:
raise TimeSliceExceeded()
def process_bucket(self, cycle, prefix, prefixdir, storage_index_b32):