summaryrefslogtreecommitdiff
path: root/zuul/connection
diff options
context:
space:
mode:
authorJames E. Blair <jim@acmegating.com>2022-02-03 14:33:08 -0800
committerJames E. Blair <jim@acmegating.com>2022-02-17 13:14:23 -0800
commitdf220cd4d6d5dae4e2b62ab2298dd3dbac88640a (patch)
tree8973a0d5e18117ea5d6ea662436d5198ec6e4fe4 /zuul/connection
parent6e991361accdbd122eae27169332a29a15d5df63 (diff)
downloadzuul-df220cd4d6d5dae4e2b62ab2298dd3dbac88640a.tar.gz
Populate missing change cache entries
The drivers are expected to populate the change cache before passing trigger events to the scheduler so that all the difficult work is done outside the main loop. Further, the cache cleanup is designed to accomodate this so that events in-flight don't have their change cache entries removed early. However, at several points since moving the change cache into ZK, programming errors have caused us to encounter enqueued changes without entries in the cache. This usually causes Zuul to abort pipeline processing and is unrecoverable. We should continue to address all incidences of those since they represent Zuul not working as designed. However, it would be nice if Zuul was able to recover from this. To that end, this change allows missing changes to be added to the change cache. That is primarily accomplished by adjusting the Source.getChange method to accept a ChangeKey instead of an Event. Events are only available when the triggering event happens, whereas a ChangeKey is available when loading the pipeline state. A ChangeKey represents the minimal distinguishing characteristics of a change, and so can be used in all cases. Some drivers obtain extra information from events, so we still pass it into the getChange method if available, but it's entirely optional -- we should still get a workable Change object whether or not it's supplied. Ref (and derived: Branch, Tag) objects currently only store their newrev attribute in the ChangeKey, however we need to be able to create Ref objects with an oldrev as well. Since the old and new revs of a Ref are not inherent to the ref but rather the generating event, we can't get that from the source system. So we need to extend the ChangeKey object to include that. Adding an extra attribute is troublesome since the ChangeKey is not a ZKObject and therefore doesn't have access to the model api version. However, it's not too much of a stretch to say that the "revision" field (which like all ChangeKey fileds is driver-dependent) should include the old and new revs. Therefore, in these cases the field is upgraded in a backwards compatible way to include old and newrev in the standard "old..new" git encoding format. We also need to support "None" since that is a valid value in Zuul. So that we can continue to identify cache errors, any time we encounter a change key that is not in the cache and we also don't have an event object, we log an error. Almost all of this commit is the refactor to accept change keys instead of events in getChange. The functional change to populate the cache if it's missing basically consists of just removing getChangeByKey and replacing it with getChange. A test which deletes the cache midway through is added. Change-Id: I4252bea6430cd434dbfaacd583db584cc796dfaa
Diffstat (limited to 'zuul/connection')
-rw-r--r--zuul/connection/__init__.py3
1 files changed, 0 insertions, 3 deletions
diff --git a/zuul/connection/__init__.py b/zuul/connection/__init__.py
index bc336fc42..abdc56c4d 100644
--- a/zuul/connection/__init__.py
+++ b/zuul/connection/__init__.py
@@ -334,8 +334,5 @@ class ZKChangeCacheMixin:
self._change_cache.updateChangeWithRetry(change.cache_stat.key,
change, _update_attrs)
- def getChangeByKey(self, key):
- return self._change_cache.get(key)
-
def estimateCacheDataSize(self):
return self._change_cache.estimateDataSize()