Skip to content

Commit

Permalink
replay-verify: print link for all mismatches
Browse files Browse the repository at this point in the history
  • Loading branch information
msmouse committed Mar 6, 2025
1 parent 6f65432 commit f2a141b
Showing 1 changed file with 22 additions and 1 deletion.
23 changes: 22 additions & 1 deletion testsuite/replay-verify/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -370,6 +370,23 @@ def __str__(self):
def get_label(self):
return f"{self.id}-{self.network}"

def humio_hash_mismatch_url(self, start_time: float, end_time: float) -> str:
query = (
f'k8s.labels.run = "{self.get_label()} | "TransactionOutput does not match"'
)

params = {
"live": "false",
"query": query,
"start": f"{int(start_time*1000)}",
"end": f"{int(end_time*1000)}",
}

encoded_params = urllib.parse.urlencode(params, quote_via=urllib.parse.quote)
url = f"https://cloud.us.humio.com/k8s/search?{encoded_params}"

return url

def sorted_ranges_to_skip(self):
if len(self.ranges_to_skip) == 0:
return []
Expand Down Expand Up @@ -684,12 +701,16 @@ def print_logs(failed_workpod_logs: list[str], txn_mismatch_logs: list[str]) ->
else:
scheduler.create_pvc_from_snapshot()
try:
start_time = time.time()
scheduler.schedule(from_scratch=True)
(failed_logs, txn_mismatch_logs) = scheduler.collect_all_failed_logs()
scheduler.print_stats()
print_logs(failed_logs, txn_mismatch_logs)
if txn_mismatch_logs:
logger.error("Transaction mismatch logs found.")
logger.error(
"Transaction mismatch logs found. All mismatch logs: {}",
scheduler.humio_hash_mismatch_url(start_time, time.time()),
)
exit(2)
if len(failed_logs) > 0:
logger.error("Failed tasks found.")
Expand Down

0 comments on commit f2a141b

Please sign in to comment.