make sure reporting stream is renamed when graph is renamed
(self)
| 234 | self.graph.config("ASYNC_DELETE", "yes", set=True) |
| 235 | |
| 236 | def test05_rename_graph(self): |
| 237 | """make sure reporting stream is renamed when graph is renamed""" |
| 238 | |
| 239 | old_name = "old_graph" |
| 240 | new_name = "new_graph" |
| 241 | old_graph = Graph(self.conn, old_name) |
| 242 | new_graph = Graph(self.conn, new_name) |
| 243 | |
| 244 | # issue query to create and populate stream |
| 245 | old_graph.query("RETURN 1") |
| 246 | |
| 247 | # wait for stream to be created |
| 248 | logged_queries = self.consumeStream(StreamName(old_graph), drop=False) |
| 249 | self.env.assertEquals(len(logged_queries), 1) |
| 250 | |
| 251 | # validate that stream exists |
| 252 | self.env.assertEquals(self.conn.type(StreamName(old_graph)), "stream") |
| 253 | |
| 254 | # rename graph |
| 255 | self.conn.rename(old_name, new_name) |
| 256 | |
| 257 | # issue query to create and populate stream |
| 258 | new_graph.query("RETURN 1") |
| 259 | |
| 260 | # wait for stream to be created |
| 261 | logged_queries = self.consumeStream(StreamName(new_graph), drop=False) |
| 262 | self.env.assertEquals(len(logged_queries), 1) |
| 263 | |
| 264 | # validate that stream was renamed |
| 265 | self.env.assertEquals(self.conn.type(StreamName(old_graph)), "none") |
| 266 | self.env.assertEquals(self.conn.type(StreamName(new_graph)), "stream") |
| 267 | |
| 268 | def test06_multiple_streams(self): |
| 269 | """test a more realistic example for how logged-queries streams |
nothing calls this directly
no test coverage detected