code: def get_worker_digests(self):
          
          try:
              builds = self.workflow.build_result.annotations['worker-builds']
          except(TypeError, KeyError):
              # This annotation is only set for the orchestrator build.
              # It's not present, so this is a worker build.
              return {}
  
          worker_digests = {}
  
          for plat, annotation in builds.items():
              digests = annotation['digests']
              self.log.debug("build %s has digests: %s", plat, digests)
  
              for digest in digests:
                  reg = registry_hostname(digest['registry'])
                  worker_digests.setdefault(reg, [])
                  worker_digests[reg].append(digest)
  
          return worker_digests
docs: If we are being called from an orchestrator build, collect the worker
           node data and recreate the data locally.