diff options
author | Zuul <zuul@review.opendev.org> | 2022-09-28 19:38:09 +0000 |
---|---|---|
committer | Gerrit Code Review <review@openstack.org> | 2022-09-28 19:38:09 +0000 |
commit | 5cb2801fad8e21c12333e66e34a7081a54ea52f3 (patch) | |
tree | 5120d5a188284201afb258f0e168ade586dd6457 | |
parent | ee277925734f744c32c4227c70bf45dae2c7e9db (diff) | |
parent | 937e25432fa19eff4c2728133568a6831dd7927e (diff) | |
download | zuul-5cb2801fad8e21c12333e66e34a7081a54ea52f3.tar.gz |
Merge "Trace node request phase"
-rw-r--r-- | zuul/manager/__init__.py | 7 | ||||
-rw-r--r-- | zuul/model.py | 5 | ||||
-rw-r--r-- | zuul/nodepool.py | 5 | ||||
-rw-r--r-- | zuul/zk/nodepool.py | 3 |
4 files changed, 17 insertions, 3 deletions
diff --git a/zuul/manager/__init__.py b/zuul/manager/__init__.py index e5e1ee69e..4cadf5440 100644 --- a/zuul/manager/__init__.py +++ b/zuul/manager/__init__.py @@ -879,8 +879,11 @@ class PipelineManager(metaclass=ABCMeta): relative_priority = item.getNodePriority() else: relative_priority = 0 - for job in jobs: - self._makeNodepoolRequest(log, build_set, job, relative_priority) + parent_span = tracing.restoreSpan(build_set.span_info) + with trace.use_span(parent_span): + for job in jobs: + self._makeNodepoolRequest( + log, build_set, job, relative_priority) return True def _makeNodepoolRequest(self, log, build_set, job, relative_priority, diff --git a/zuul/model.py b/zuul/model.py index e50594a2d..536e7fecc 100644 --- a/zuul/model.py +++ b/zuul/model.py @@ -1519,7 +1519,7 @@ class NodeRequest(object): def __init__(self, requestor, build_set_uuid, tenant_name, pipeline_name, job_name, labels, provider, relative_priority, - event_id=None): + event_id=None, span_info=None): self.requestor = requestor self.build_set_uuid = build_set_uuid self.tenant_name = tenant_name @@ -1537,6 +1537,7 @@ class NodeRequest(object): self.id = None self._zk_data = {} # Data that we read back from ZK self.event_id = event_id + self.span_info = span_info # Zuul internal flags (not stored in ZK so they are not # overwritten). self.failed = False @@ -1587,6 +1588,7 @@ class NodeRequest(object): "tenant_name": self.tenant_name, "pipeline_name": self.pipeline_name, "job_name": self.job_name, + "span_info": self.span_info, } d.setdefault('node_types', self.labels) d.setdefault('requestor', self.requestor) @@ -1635,6 +1637,7 @@ class NodeRequest(object): labels=data["node_types"], provider=data["provider"], relative_priority=data.get("relative_priority", 0), + span_info=requestor_data.get("span_info"), ) request.updateFromDict(data) diff --git a/zuul/nodepool.py b/zuul/nodepool.py index 61b0417c8..1118fe0c2 100644 --- a/zuul/nodepool.py +++ b/zuul/nodepool.py @@ -16,6 +16,7 @@ import time from collections import defaultdict from zuul import model +from zuul.lib import tracing from zuul.lib.logutil import get_annotated_logger from zuul.zk.event_queues import ( PipelineResultEventQueue, @@ -100,6 +101,10 @@ class Nodepool(object): continue if (request.state in {model.STATE_FULFILLED, model.STATE_FAILED}): + tracing.endSavedSpan(request.span_info, attributes={ + "request_id": request.id, + "state": request.state, + }) self._sendNodesProvisionedEvent(request) # Now resume normal event processing. self.stop_watcher_event.wait() diff --git a/zuul/zk/nodepool.py b/zuul/zk/nodepool.py index 1be4dc2b5..6675ff3be 100644 --- a/zuul/zk/nodepool.py +++ b/zuul/zk/nodepool.py @@ -23,6 +23,7 @@ from kazoo.recipe.cache import TreeCache, TreeEvent from kazoo.recipe.lock import Lock import zuul.model +from zuul.lib import tracing from zuul.lib.jsonutil import json_dumps from zuul.model import HoldRequest, NodeRequest, Node from zuul.zk import ZooKeeperBase @@ -456,6 +457,8 @@ class ZooKeeperNodepool(ZooKeeperBase): contents of the request. """ node_request.created_time = time.time() + node_request.span_info = tracing.startSavedSpan( + "RequestNodes", start_time=node_request.created_time) data = node_request.toDict() path = '{}/{:0>3}-'.format(self.REQUEST_ROOT, priority) |