diff options
| author | Zuul <zuul@review.opendev.org> | 2022-10-04 10:29:08 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2022-10-04 10:29:08 +0000 |
| commit | e8a0a62a1d684a8ce7b6c22a3441fecdd3bce0d8 (patch) | |
| tree | ff58ce026a2ed2ebfc5386285f86573ea2b834ac | |
| parent | b0122bd56a707abacbd7a87476ea4488d56594fd (diff) | |
| parent | 33edf53f36d58c5e1bef81f9d60356a8ccab01b7 (diff) | |
| download | zuul-e8a0a62a1d684a8ce7b6c22a3441fecdd3bce0d8.tar.gz | |
Merge "Trace Git connection events"
| -rw-r--r-- | zuul/driver/git/gitwatcher.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/zuul/driver/git/gitwatcher.py b/zuul/driver/git/gitwatcher.py index 68f1f95ef..07161247d 100644 --- a/zuul/driver/git/gitwatcher.py +++ b/zuul/driver/git/gitwatcher.py @@ -19,6 +19,7 @@ import logging import threading import git +from opentelemetry import trace from zuul.driver.git.gitmodel import EMPTY_GIT_REF from zuul.zk.event_queues import EventReceiverElection @@ -27,6 +28,7 @@ from zuul.zk.event_queues import EventReceiverElection # This class may be used by any driver to implement git head polling. class GitWatcher(threading.Thread): log = logging.getLogger("zuul.connection.git.watcher") + tracer = trace.get_tracer("zuul") def __init__(self, connection, baseurl, poll_delay, callback, election_name="watcher"): @@ -134,8 +136,9 @@ class GitWatcher(threading.Thread): self.projects_refs[project] = refs # Send events to the scheduler for event in events: - self.log.debug("Sending event: %s" % event) - self.callback(event) + with self.tracer.start_as_current_span("GitEvent"): + self.log.debug("Sending event: %s" % event) + self.callback(event) self._event_count += 1 def _run(self): |