(name, txn_id)
| 57 | raise Exception(f"Failed to commit transaction: {response.text}") |
| 58 | |
| 59 | def abort_transaction(name, txn_id): |
| 60 | url = f"{client.base_url}/collections/{name}/transactions/{txn_id}/abort" |
| 61 | response = requests.post(url, headers=client._get_headers(), verify=client.verify_ssl) |
| 62 | if response.status_code not in [200, 204]: |
| 63 | raise Exception(f"Failed to abort transaction: {response.text}") |
| 64 | |
| 65 | def upsert(name, txn_id, key: str, value: str): |
| 66 | url = f"{client.base_url}/collections/{name}/transactions/{txn_id}/upsert" |
no test coverage detected