(collection_name, transaction_id)
| 155 | |
| 156 | |
| 157 | def abort_transaction(collection_name, transaction_id): |
| 158 | url = ( |
| 159 | f"{base_url}/collections/{collection_name}/transactions/{transaction_id}/abort" |
| 160 | ) |
| 161 | response = requests.post(url, headers=generate_headers(), verify=False) |
| 162 | if response.status_code not in [200, 204]: |
| 163 | print(f"Error aborting transaction: {response.status_code} ({response.text})") |
| 164 | return response.json() if response.status_code == 200 and response.text else None |
| 165 | |
| 166 | |
| 167 | def batch_ann_search(vector_db_name, vectors): |
no test coverage detected