zuul
/
zuul
Code Issues Proposed changes

Merge "Enable maintainConnectionCache" into feature/zuulv3

This commit is contained in:
Zuul 2017-09-07 19:07:42 +00:00 committed by Gerrit Code Review
parent 9c5767c657 517fd7741d
commit b143da59fe
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
zuul/scheduler.py
View File

@ -585,8 +585,7 @@ class Scheduler(threading.Thread):
self._reenqueueTenant(old_tenant, tenant)
# TODOv3(jeblair): update for tenants
# self.maintainConnectionCache()
self.maintainConnectionCache()
self.connections.reconfigureDrivers(tenant)
# TODOv3(jeblair): remove postconfig calls?
@ -719,7 +718,6 @@ class Scheduler(threading.Thread):
self.run_handler_lock.release()
def maintainConnectionCache(self):
# TODOv3(jeblair): update for tenants
relevant = set()
for tenant in self.abide.tenants.values():
for pipeline in tenant.layout.pipelines.values():
@ -729,7 +727,7 @@ class Scheduler(threading.Thread):
for item in pipeline.getAllItems():
relevant.add(item.change)
relevant.update(item.change.getRelatedChanges())
for connection in self.connections.values():
for connection in self.connections.connections.values():
connection.maintainCache(relevant)
self.log.debug(
"End maintain connection cache for: %s" % connection)