diff --git a/src/work.py b/src/work.py --- a/src/work.py +++ b/src/work.py @@ -15,7 +15,7 @@ DB_NAME="morevna.db" FILE_COUNT=2**21 TARGET_DIR="temp" -log.basicConfig(level=log.DEBUG) +log.basicConfig(format="{asctime} {levelname}: {message}", style="{", level=log.DEBUG) class Pipeline: def __init__(self,fileName): @@ -29,8 +29,9 @@ class Pipeline: def update(self): log.info("starting update") for (i,(chunk,storedHashRec)) in enumerate(zip_longest(self.chunks(), self.db.listHashes())): + assert storedHashRec is None or storedHashRec["sector_id"]==i, "{0}!={1} {2}".format(i, storedHashRec["sector_id"], storedHashRec) if not chunk: break - hash=self.hash(chunk) + hash=Pipeline.hash(chunk) storedHash=(storedHashRec and storedHashRec["sector_hash"]) or b"\0" if hash==storedHash: continue log.info("updating sector %d, hash %s != stored %s", i, hash.hex(), storedHash.hex())