diff options
| author | Mitja Felicijan <mitja.felicijan@gmail.com> | 2026-01-21 22:52:54 +0100 |
|---|---|---|
| committer | Mitja Felicijan <mitja.felicijan@gmail.com> | 2026-01-21 22:52:54 +0100 |
| commit | dcacc00e3750300617ba6e16eb346713f91a783a (patch) | |
| tree | 38e2d4fb5ed9d119711d4295c6eda4b014af73fd /examples/redis-unstable/modules/vector-sets/tests/concurrent_vsim_and_del.py | |
| parent | 58dac10aeb8f5a041c46bddbeaf4c7966a99b998 (diff) | |
| download | crep-dcacc00e3750300617ba6e16eb346713f91a783a.tar.gz | |
Remove testing data
Diffstat (limited to 'examples/redis-unstable/modules/vector-sets/tests/concurrent_vsim_and_del.py')
| -rw-r--r-- | examples/redis-unstable/modules/vector-sets/tests/concurrent_vsim_and_del.py | 48 |
1 files changed, 0 insertions, 48 deletions
diff --git a/examples/redis-unstable/modules/vector-sets/tests/concurrent_vsim_and_del.py b/examples/redis-unstable/modules/vector-sets/tests/concurrent_vsim_and_del.py deleted file mode 100644 index 9bbf011..0000000 --- a/examples/redis-unstable/modules/vector-sets/tests/concurrent_vsim_and_del.py +++ /dev/null @@ -1,48 +0,0 @@ -from test import TestCase, fill_redis_with_vectors, generate_random_vector -import threading, time - -class ConcurrentVSIMAndDEL(TestCase): - def getname(self): - return "Concurrent VSIM and DEL operations" - - def estimated_runtime(self): - return 2 - - def test(self): - # Fill the key with 5000 random vectors - dim = 128 - count = 5000 - fill_redis_with_vectors(self.redis, self.test_key, count, dim) - - # List to store results from threads - thread_results = [] - - def vsim_thread(): - """Thread function to perform VSIM operations until the key is deleted""" - while True: - query_vec = generate_random_vector(dim) - result = self.redis.execute_command('VSIM', self.test_key, 'VALUES', dim, - *[str(x) for x in query_vec], 'COUNT', 10) - if not result: - # Empty array detected, key is deleted - thread_results.append(True) - break - - # Start multiple threads to perform VSIM operations - threads = [] - for _ in range(4): # Start 4 threads - t = threading.Thread(target=vsim_thread) - t.start() - threads.append(t) - - # Delete the key while threads are still running - time.sleep(1) - self.redis.delete(self.test_key) - - # Wait for all threads to finish (they will exit once they detect the key is deleted) - for t in threads: - t.join() - - # Verify that all threads detected an empty array or error - assert len(thread_results) == len(threads), "Not all threads detected the key deletion" - assert all(thread_results), "Some threads did not detect an empty array or error after DEL" |
