diff options
| author | Simon Westphahl <simon.westphahl@bmw.de> | 2023-01-05 13:54:40 +0100 |
|---|---|---|
| committer | Simon Westphahl <simon.westphahl@bmw.de> | 2023-02-06 08:06:22 +0100 |
| commit | ec5d50d1776cd8dd5706f7410e30581858318c00 (patch) | |
| tree | 4e2fc881d93a0d5db02ef57cdee6ea56766d7844 | |
| parent | 95ecb41c51c4a766d254ec05f32ec9c1f0472d4f (diff) | |
| download | zuul-ec5d50d1776cd8dd5706f7410e30581858318c00.tar.gz | |
Add more log messages for run handler steps
This change adds distinct log message for certain run handler steps.
So far some of those phases could only be inferred by other related log
messages.
Change-Id: Icceca78456b20754cbebb5747da3a538586cd5f5
| -rw-r--r-- | zuul/scheduler.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/zuul/scheduler.py b/zuul/scheduler.py index f22d20a05..70eca4f28 100644 --- a/zuul/scheduler.py +++ b/zuul/scheduler.py @@ -1548,7 +1548,6 @@ class Scheduler(threading.Thread): # This is called in the scheduler loop after another thread submits # a request if self.unparsed_abide.ltime < self.system_config_cache.ltime: - self.log.debug("Updating system config") self.updateSystemConfig() with self.layout_lock: @@ -2211,6 +2210,7 @@ class Scheduler(threading.Thread): def updateSystemConfig(self): with self.layout_lock: + self.log.debug("Updating system config") self.unparsed_abide, self.globals = self.system_config_cache.get() self.ansible_manager = AnsibleManager( default_version=self.globals.default_ansible_version) @@ -2245,6 +2245,8 @@ class Scheduler(threading.Thread): self.zk_client, tenant.name, pipeline.name, blocking=False) as lock,\ self.createZKContext(lock, self.log) as ctx: + self.log.debug("Processing pipeline %s in tenant %s", + pipeline.name, tenant.name) with pipeline.manager.currentContext(ctx): with self.statsd_timer(f'{stats_key}.handling'): refreshed = self._process_pipeline( @@ -2384,6 +2386,8 @@ class Scheduler(threading.Thread): with trigger_queue_lock( self.zk_client, tenant.name, blocking=False ): + self.log.debug("Processing tenant trigger events in %s", + tenant.name) # Update the pipeline changes ctx = self.createZKContext(None, self.log) for pipeline in tenant.layout.pipelines.values(): @@ -2584,6 +2588,8 @@ class Scheduler(threading.Thread): "Skipping management event queue for tenant %s", tenant.name) return + self.log.debug("Processing tenant management events in %s", + tenant.name) self._process_tenant_management_queue(tenant) except LockException: self.log.debug("Skipping locked management event queue" |