diff --git a/workers/tagbackfillworker.py b/workers/tagbackfillworker.py index fa5f5b8d0..9e6671183 100644 --- a/workers/tagbackfillworker.py +++ b/workers/tagbackfillworker.py @@ -156,7 +156,7 @@ class TagBackfillWorker(Worker): for candidate, abt, _ in iterator: if not backfill_tag(candidate): - logger.info('Another worker pre-empted us for label: %s', candidate.id) + logger.info('Another worker pre-empted us for tag: %s', candidate.id) abt.set() @@ -171,14 +171,14 @@ def lookup_map_row(repositorytag): def backfill_tag(repositorytag): logger.info('Backfilling tag %s', repositorytag.id) - # Ensure that a mapping row doesn't already exist. If it does, we've been preempted. + # Ensure that a mapping row doesn't already exist. If it does, nothing more to do. if lookup_map_row(repositorytag): return False # Grab the manifest for the RepositoryTag, backfilling as necessary. manifest_id = _get_manifest_id(repositorytag) if manifest_id is None: - return False + return True lifetime_start_ms = (repositorytag.lifetime_start_ts * 1000 if repositorytag.lifetime_start_ts is not None else None)