summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rwxr-xr-xpython/skytools/checker.py7
1 files changed, 6 insertions, 1 deletions
diff --git a/python/skytools/checker.py b/python/skytools/checker.py
index 785cd9d6..cb9f9895 100755
--- a/python/skytools/checker.py
+++ b/python/skytools/checker.py
@@ -452,7 +452,7 @@ class Checker(Syncer):
extra_connstr = user=marko
- # one of: compare, repair, repair-apply
+ # one of: compare, repair, repair-apply, compare-repair-apply
check_type = compare
# random params used in queries
@@ -552,6 +552,11 @@ class Checker(Syncer):
elif check == 'repair-apply':
r = TableRepair(tbl, self.log)
r.do_repair(src_db, dst_db, where, 'fix.' + tbl, True)
+ elif check == 'compare-repair-apply':
+ ok = self.do_compare(tbl, src_db, dst_db, where)
+ if not ok:
+ r = TableRepair(tbl, self.log)
+ r.do_repair(src_db, dst_db, where, 'fix.' + tbl, True)
else:
raise Exception('unknown check type')
self.reset()