Skip to content
Snippets Groups Projects

Indicate where artifacts are going to and coming from in the log

Merged Qinusty requested to merge Qinusty/275 into master
1 file
+ 4
2
Compare changes
  • Side-by-side
  • Inline
@@ -220,6 +220,8 @@ class CASCache(ArtifactCache):
for remote in self._remotes[project]:
try:
remote.init()
element.info("Pulling {} <- {}".format(element._get_brief_display_key(), remote.spec.url))
request = buildstream_pb2.GetReferenceRequest()
request.key = ref
@@ -228,7 +230,6 @@ class CASCache(ArtifactCache):
tree = remote_execution_pb2.Digest()
tree.hash = response.digest.hash
tree.size_bytes = response.digest.size_bytes
self._fetch_directory(remote, tree)
self.set_ref(ref, tree)
@@ -238,6 +239,7 @@ class CASCache(ArtifactCache):
except grpc.RpcError as e:
if e.code() != grpc.StatusCode.NOT_FOUND:
element.info("{} not found at remote {}".format(element._get_brief_display_key(), remote.spec.url))
raise
return False
@@ -258,7 +260,7 @@ class CASCache(ArtifactCache):
push_remotes = [r for r in self._remotes[project] if r.spec.push]
pushed = False
for remote in push_remotes:
remote.init()
Loading