diff --git a/octavia/controller/worker/tasks/database_tasks.py b/octavia/controller/worker/tasks/database_tasks.py index e4d3a354c9..0934d50ea4 100644 --- a/octavia/controller/worker/tasks/database_tasks.py +++ b/octavia/controller/worker/tasks/database_tasks.py @@ -478,6 +478,14 @@ class MapLoadbalancerToAmphora(BaseDatabaseTask): return amp.id + def revert(self, result, loadbalancer_id, *args, **kwargs): + LOG.warning(_LW("Reverting Amphora allocation for the load " + "balancer %s in the database."), loadbalancer_id) + + self.loadbalancer_repo.update(db_apis.get_session(), + loadbalancer_id, + provisioning_status=constants.ERROR) + class _MarkAmphoraRoleAndPriorityInDB(BaseDatabaseTask): """Alter the amphora role and priority in DB."""