adding flushall after memtier benchmark failure. Otherwise the database may be in a corrupted state for the next test

Author: slice4e

redis_benchmarks_specification/__runner__/runner.py

@@ -2671,6 +2671,14 @@ def delete_temporary_files(
 
                             if not success:
                                 logging.error(f"Memtier benchmark failed: {stderr}")
+                                # Clean up database after failure (timeout or error)
+                                if args.flushall_on_every_test_end or args.flushall_on_every_test_start:
+                                    logging.warning("Benchmark failed - cleaning up database with FLUSHALL")
+                                    try:
+                                        for r in redis_conns:
+                                            r.flushall()
+                                    except Exception as e:
+                                        logging.error(f"FLUSHALL failed after benchmark failure: {e}")
                                 # Continue with the test but log the failure
                                 client_container_stdout = f"ERROR: {stderr}"