make sure reporting stream is deleted when graph is deleted
(self)
| 215 | self.env.assertEquals(logged_query.Query, q) |
| 216 | |
| 217 | def test04_delete_graph(self): |
| 218 | """make sure reporting stream is deleted when graph is deleted""" |
| 219 | |
| 220 | # validate that stream exists |
| 221 | stream_name = StreamName(self.graph) |
| 222 | self.env.assertEquals(self.conn.type(stream_name), "stream") |
| 223 | |
| 224 | # make sure graph is deleted synchronously |
| 225 | self.graph.config("ASYNC_DELETE", "no", set=True) |
| 226 | |
| 227 | # delete graph |
| 228 | self.graph.delete() |
| 229 | |
| 230 | # validate that stream was deleted |
| 231 | self.env.assertEquals(self.conn.type(stream_name), "none") |
| 232 | |
| 233 | # restore ASYNC_DELETE |
| 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""" |
nothing calls this directly
no test coverage detected