diff --git a/octavia/controller/worker/tasks/database_tasks.py b/octavia/controller/worker/tasks/database_tasks.py index 8c86bbd226..8b5474183a 100644 --- a/octavia/controller/worker/tasks/database_tasks.py +++ b/octavia/controller/worker/tasks/database_tasks.py @@ -1536,9 +1536,9 @@ class GetAmphoraeFromLoadbalancer(BaseDatabaseTask): """ amphorae = [] for amp in loadbalancer.amphorae: - a = self.amphora_repo.get(db_apis.get_session(), id=amp.id, - show_deleted=False) - if a is None: + a = self.amphora_repo.get(db_apis.get_session(), id=amp.id) + + if a is None or a.status == constants.DELETED: continue amphorae.append(a) return amphorae