Update benchmark

Author: Kimahriman

python/tests/test_benchmark.py

@@ -1,4 +1,4 @@
-from concurrent.futures import ThreadPoolExecutor
+from concurrent.futures import ThreadPoolExecutor, as_completed
 
 import pytest
 from pytest_benchmark.fixture import BenchmarkFixture
@@ -7,17 +7,19 @@
 
 
 def do_work(client: Client):
-    def delete(path: str):
-        client.delete(path)
+    def func(path: str):
+        client.create(path).close()
+        return client.delete(path)
 
     with ThreadPoolExecutor(100) as executor:
-        for i in range(100):
-            executor.submit(delete, f"/bench{i}")
+        futures = []
+        for i in range(1000):
+            futures.append(executor.submit(func, f"/bench{i}"))
+
+        for future in as_completed(futures):
+            assert future.result()
 
 
 @pytest.mark.benchmark
 def test_threading(client: Client, benchmark: BenchmarkFixture):
-    for i in range(100):
-        client.create(f"/bench{i}").close()
-
     benchmark(do_work, client)