Add UUID for queue items
When storing e.g. the queue or semaphore state in Zookeeper we need a unique identifier when referencing a queue item. Change-Id: I9cc5b896c242009a8eea57bd56845578cd57efde
This commit is contained in:
parent
b268f71b23
commit
0101820328
|
@ -2232,6 +2232,7 @@ class QueueItem(object):
|
||||||
def __init__(self, queue, change, event):
|
def __init__(self, queue, change, event):
|
||||||
log = logging.getLogger("zuul.QueueItem")
|
log = logging.getLogger("zuul.QueueItem")
|
||||||
self.log = get_annotated_logger(log, event)
|
self.log = get_annotated_logger(log, event)
|
||||||
|
self.uuid = uuid4().hex
|
||||||
self.pipeline = queue.pipeline
|
self.pipeline = queue.pipeline
|
||||||
self.queue = queue
|
self.queue = queue
|
||||||
self.change = change # a ref
|
self.change = change # a ref
|
||||||
|
@ -2273,8 +2274,8 @@ class QueueItem(object):
|
||||||
pipeline = self.pipeline.name
|
pipeline = self.pipeline.name
|
||||||
else:
|
else:
|
||||||
pipeline = None
|
pipeline = None
|
||||||
return '<QueueItem 0x%x for %s in %s>' % (
|
return '<QueueItem %s for %s in %s>' % (
|
||||||
id(self), self.change, pipeline)
|
self.uuid, self.change, pipeline)
|
||||||
|
|
||||||
def resetAllBuilds(self):
|
def resetAllBuilds(self):
|
||||||
self.current_build_set = BuildSet(self)
|
self.current_build_set = BuildSet(self)
|
||||||
|
|
Loading…
Reference in New Issue