[sqlalchemy-20] Add missing DB context decorator
One query was being executed without context decorator, leading to warning messages in the log. Closes-Bug: 1980671 Change-Id: Iebdc16e32193a6bc1eea5ea69c16f4aca5bd4526
This commit is contained in:
@@ -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):
|
||||
|
||||
Reference in New Issue
Block a user