Update test insert

diff --git a/itest/test_insert.py b/itest/test_insert.py
index 6dcbc20d73901baf8784edc06cbed7abc6d1c5d0..bc0aebb08c5c6c2b61100c7f7e6ce1312ed06f75 100644 (file)
--- a/itest/test_insert.py
+++ b/itest/test_insert.py
@@ -165,19 +165,19 @@ class TestInsert(TestBase):
         await self.assertSeries(self.client0, series)
         await self.assertSeries(self.client1, series)
 
-        # tasks = [
-        #     asyncio.ensure_future(self.client0.query(
-        #             'drop series /.*/ set ignore_threshold true'))
-        #     for i in range(5)]
+        tasks = [
+            asyncio.ensure_future(self.client0.query(
+                    'drop series /.*/ set ignore_threshold true'))
+            for i in range(5)]
 
-        # await asyncio.gather(*tasks)
+        await asyncio.gather(*tasks)
 
-        # tasks = [
-        #     asyncio.ensure_future(self.client0.query(
-        #             'drop shards set ignore_threshold true'))
-        #     for i in range(5)]
+        tasks = [
+            asyncio.ensure_future(self.client0.query(
+                    'drop shards set ignore_threshold true'))
+            for i in range(5)]
 
-        # await asyncio.gather(*tasks)
+        await asyncio.gather(*tasks)
 
         await asyncio.sleep(2)