From bbf949a1bf92d4efc8d3fb6f1b2ad2c1e02c6103 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=BCrg=20Billeter?= Date: Thu, 29 Aug 2019 12:47:53 +0200 Subject: casremote.py: Remove unused _fetch_blob() method This removes code duplication with _CASBatchRead. --- src/buildstream/_cas/casremote.py | 19 ------------------- 1 file changed, 19 deletions(-) diff --git a/src/buildstream/_cas/casremote.py b/src/buildstream/_cas/casremote.py index 183429a77..23240c6f7 100644 --- a/src/buildstream/_cas/casremote.py +++ b/src/buildstream/_cas/casremote.py @@ -247,25 +247,6 @@ class CASRemote(): return self.cascache.add_object(buffer=message_buffer, instance_name=self.local_cas_instance_name) - ################################################ - # Local Private Methods # - ################################################ - def _fetch_blob(self, digest): - local_cas = self.cascache._get_local_cas() - request = local_cas_pb2.FetchMissingBlobsRequest() - request.instance_name = self.local_cas_instance_name - request_digest = request.blob_digests.add() - request_digest.CopyFrom(digest) - response = local_cas.FetchMissingBlobs(request) - for blob_response in response.responses: - if blob_response.status.code == code_pb2.NOT_FOUND: - raise BlobNotFound(response.digest.hash, "Failed to download blob {}: {}".format( - blob_response.digest.hash, blob_response.status.code)) - - if blob_response.status.code != code_pb2.OK: - raise CASRemoteError("Failed to download blob {}: {}".format( - blob_response.digest.hash, blob_response.status.code)) - # Represents a batch of blobs queued for fetching. # -- cgit v1.2.1