'Test that get_replication_status fails on exception'

def test_get_replication_status_fail_on_exception(self):

    self.driver.do_setup(None)
    replicated_volume = copy.deepcopy(REPLICATED_VOLUME)
    replicated_volume['replication_status'] = 'invalid_status_val'
    self.assertRaises(exception.CinderException, self.driver.get_replication_status, CONTEXT, replicated_volume)
