(i)
| 272 | |
| 273 | # _run_query is expected to be issued by multiple threads |
| 274 | def _run_query(i): |
| 275 | #random param name |
| 276 | param_name = 'p_' + str(i) |
| 277 | q = f"MATCH (n) WHERE n.v = ${param_name} RETURN count(n)" |
| 278 | params = {param_name : '/'} |
| 279 | g = Graph(self.env.getConnection(), 'cache_eviction') |
| 280 | count = g.query(q, params).result_set[0][0] |
| 281 | self.env.assertEqual(count, 10001) |
| 282 | |
| 283 | tasks = [] |
| 284 | loop = asyncio.get_event_loop() |