From fa3f36a81426ab70dced87b0791f50f666a5a3a7 Mon Sep 17 00:00:00 2001 From: Julian Nguyen <109386615+juliannguyen4@users.noreply.github.com> Date: Wed, 2 Oct 2024 16:35:28 -0700 Subject: [PATCH] cleanup --- test/mrts/test.py | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/test/mrts/test.py b/test/mrts/test.py index 18f491b21..71681dcf7 100644 --- a/test/mrts/test.py +++ b/test/mrts/test.py @@ -51,30 +51,16 @@ def test_commit_api_and_functionality(self, get_status: bool): # Test case 57: "Execute the MRT. Before issuing commit, give abort request using abort API" (P1) @pytest.mark.parametrize("get_status", [False, True]) def test_abort_api_and_functionality(self, get_status: bool): - # Make sure test fixture worked - _, _, bins = self.as_connection.get(self.keys[0]) - assert bins == {self.bin_name: 0} - _, _, bins = self.as_connection.get(self.keys[1]) - assert bins == {self.bin_name: 1} - mrt = aerospike.Transaction() policy = { "txn": mrt } self.as_connection.put(self.keys[0], {self.bin_name: 1}, policy=policy) # Should return intermediate overwritten value from MRT - # TODO: broken _, _, bins = self.as_connection.get(self.keys[0], policy) assert bins == {self.bin_name: 1} self.as_connection.put(self.keys[1], {self.bin_name: 2}, policy=policy) - digest = aerospike.calc_digest(*self.keys[0]) - print(digest) - res = self.as_connection.info_all(f"debug-record:namespace=test;keyd={digest.hex()}") - print(res) - digest = aerospike.calc_digest(*self.keys[1]) - print(digest) - res = self.as_connection.info_all(f"debug-record:namespace=test;keyd={digest.hex()}") - print(res) + retval = self.as_connection.abort(transaction=mrt, get_abort_status=get_status) if get_status: assert type(retval) is int