@@ -112,6 +112,7 @@ post_data('event', {'type': 'start'}, 1)
start = time()
sources = db().sources()
db().purge_error()
+post_data('event', {'type': 'purge_complete'}, 1)
pool = Pool(processes=4)
ret = pool.map(parseSource, sources)
new = sum([r[3] for r in ret])