Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
juliannguyen4 committed Oct 2, 2024
1 parent f897422 commit fa3f36a
Showing 1 changed file with 1 addition and 15 deletions.
16 changes: 1 addition & 15 deletions test/mrts/test.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit fa3f36a

Please sign in to comment.