summaryrefslogtreecommitdiff
path: root/zuul/cmd/scheduler.py
diff options
context:
space:
mode:
authorJan Kubovy <jan.kubovy@bmw.de>2021-02-08 15:29:43 +0100
committerJames E. Blair <jim@acmegating.com>2021-03-08 18:51:32 -0800
commit5d1aeeffb5887b8fa167c1d74734a292d4cecd05 (patch)
tree7cce5c553c086fde636de35a679705e20fc93b14 /zuul/cmd/scheduler.py
parent2dfb34a81800bd3973a6a62ee23d147cadae3cad (diff)
downloadzuul-5d1aeeffb5887b8fa167c1d74734a292d4cecd05.tar.gz
Make ConnectionRegistry mandatory for Scheduler
So far the connection registry was added after the Scheduler was instantiated. We can make the ConnectionRegistry mandatory to simplify the Scheduler instantiation. Change-Id: Iff7b1a597c97f2cd13bea75f9f23585b0e7f76b3
Diffstat (limited to 'zuul/cmd/scheduler.py')
-rwxr-xr-xzuul/cmd/scheduler.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/zuul/cmd/scheduler.py b/zuul/cmd/scheduler.py
index 42d6e0f31..89435b39d 100755
--- a/zuul/cmd/scheduler.py
+++ b/zuul/cmd/scheduler.py
@@ -138,12 +138,13 @@ class Scheduler(zuul.cmd.ZuulDaemonApp):
self.setup_logging('scheduler', 'log_config')
self.log = logging.getLogger("zuul.Scheduler")
- self.sched = zuul.scheduler.Scheduler(self.config)
+ self.configure_connections(require_sql=True)
+ self.sched = zuul.scheduler.Scheduler(self.config, self.connections)
+ if self.args.validate_tenants is None:
+ self.connections.registerScheduler(self.sched)
self.sched.setZuulApp(self)
merger = zuul.merger.client.MergeClient(self.config, self.sched)
-
- self.configure_connections(require_sql=True)
self.sched.setMerger(merger)
if self.args.validate_tenants is None:
@@ -159,7 +160,6 @@ class Scheduler(zuul.cmd.ZuulDaemonApp):
self.log.info('Starting scheduler')
try:
self.sched.start()
- self.sched.registerConnections(self.connections)
self.sched.reconfigure(self.config,
validate_tenants=self.args.validate_tenants)
self.sched.wakeUp()