Method query

tests/flow/test_timeout.py:297–301

()

        redis_graph.query("UNWIND range(1, 1000) AS x CREATE (:N {v:x})")

        def query():
            g = Graph(self.env.getConnection(), GRAPH_ID)

            for i in range(1, 1000):
                g.query(f"MATCH (n:N) WHERE n.v > {i} RETURN count(1)", timeout=1000)

        loop = asyncio.get_event_loop()
        tasks = []