'Test that no notifications are rescheduled when a flow raises.'

def testNoNotificationRescheduling(self):

    with test_lib.FakeTime(10000):
        flow_obj = self.FlowSetup('RaisingTestFlow')
        session_id = flow_obj.session_id
        flow_obj.Close()
        self.SendResponse(session_id, 'Hello1', request_id=1)
        self.SendResponse(session_id, 'Hello2', request_id=2)
        self.SendResponse(session_id, 'Hello3', request_id=3)
        worker_obj = worker.GRRWorker(token=self.token)
        worker_obj.RunOnce()
        worker_obj.thread_pool.Join()
    delay = flow_runner.FlowRunner.notification_retry_interval
    with test_lib.FakeTime(((10000 + 100) + delay)):
        manager = queue_manager.QueueManager(token=self.token)
        self.assertFalse(manager.GetNotificationsForAllShards(session_id.Queue()))
