openstack
/
neutron-dynamic-routing
Code Issues Proposed changes

Merge "[sqlalchemy-20] Add missing DB context decorator"

This commit is contained in:
Zuul 2022-07-11 12:20:45 +00:00 committed by Gerrit Code Review
parent f9b9ae70a4 0d2782fb7e
commit 608037e8fa
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
neutron_dynamic_routing/db/bgp_dragentscheduler_db.py
View File

@ -149,12 +149,13 @@ class BgpDrAgentSchedulerDbMixin(bgp_dras_ext.BgpDrSchedulerPluginBase,
def get_down_bgp_speaker_bindings(self, context, agent_dead_limit):
cutoff = self.get_cutoff_time(agent_dead_limit)
query = (
context.session.query(BgpSpeakerDrAgentBinding).
join(agent_model.Agent).
filter(agent_model.Agent.heartbeat_timestamp < cutoff,
agent_model.Agent.admin_state_up))
down_bindings = [b for b in query]
with db_api.CONTEXT_READER.using(context):
query = (
context.session.query(BgpSpeakerDrAgentBinding).
join(agent_model.Agent).
filter(agent_model.Agent.heartbeat_timestamp < cutoff,
agent_model.Agent.admin_state_up))
down_bindings = [b for b in query]
return down_bindings
def reschedule_bgp_speaker(self, context, bgp_speaker_id):