buildgrid/_app/settings/cas.yml

+server:
+  port: 50052
+  insecure-mode: true
+  tls-server-key: null
+  tls-server-cert: null
+  tls-client-certs: null
+
+description: |
+  Just a CAS.
+
+instances:
+  - name: main
+    description: |
+      The main server
+
+    storages:
+        - !disk-storage &main-storage
+          path: ~/cas/
+
+    services:
+      - !cas
+        storage: *main-storage
+
+      - !bytestream
+        storage: *main-storage

buildgrid/_app/settings/default.yml

 server:
   port: 50051
+  insecure-mode: true
   tls-server-key: null
   tls-server-cert: null
   tls-client-certs: null
-  insecure-mode: true
 
 description: |
   A single default instance

buildgrid/_app/settings/remote-storage.yml

+server:
+  port: 50051
+  insecure-mode: true
+  tls-server-key: null
+  tls-server-cert: null
+  tls-client-certs: null
+
+
+description: |
+  A single default instance with remote storage.
+
+instances:
+  - name: main
+    description: |
+      The main server
+
+    storages:
+        - !remote-storage &main-storage
+          url: "http://localhost:50052"
+          credentials:
+            tls-client-key: null
+            tls-client-cert: null
+            tls-server-cert: null
+
+    services:
+      - !action-cache &main-action
+        storage: *main-storage
+        max_cached_refs: 256
+        allow_updates: true
+
+      - !execution
+        storage: *main-storage
+        action_cache: *main-action
+
+      - !cas
+        storage: *main-storage
+
+      - !bytestream
+        storage: *main-storage

buildgrid/server/cas/service.py

@@ -89,15 +89,15 @@ class ByteStreamService(bytestream_pb2_grpc.ByteStreamServicer):
             # TODO: Decide on default instance name
             if path[0] == "blobs":
                 if len(path) < 3 or not path[2].isdigit():
-                    raise InvalidArgumentError("Invalid resource name: {}".format(context.resource_name))
+                    raise InvalidArgumentError("Invalid resource name: {}".format(request.resource_name))
                 instance_name = ""
 
             elif path[1] == "blobs":
                 if len(path) < 4 or not path[3].isdigit():
-                    raise InvalidArgumentError("Invalid resource name: {}".format(context.resource_name))
+                    raise InvalidArgumentError("Invalid resource name: {}".format(request.resource_name))
 
             else:
-                raise InvalidArgumentError("Invalid resource name: {}".format(context.resource_name))
+                raise InvalidArgumentError("Invalid resource name: {}".format(request.resource_name))
 
             instance = self._get_instance(instance_name)
             yield from instance.read(path,
@@ -134,15 +134,15 @@ class ByteStreamService(bytestream_pb2_grpc.ByteStreamServicer):
             # TODO: Sort out no instance name
             if path[0] == "uploads":
                 if len(path) < 5 or path[2] != "blobs" or not path[4].isdigit():
-                    raise InvalidArgumentError("Invalid resource name: {}".format(context.resource_name))
+                    raise InvalidArgumentError("Invalid resource name: {}".format(first_request.resource_name))
                 instance_name = ""
 
             elif path[1] == "uploads":
                 if len(path) < 6 or path[3] != "blobs" or not path[5].isdigit():
-                    raise InvalidArgumentError("Invalid resource name: {}".format(context.resource_name))
+                    raise InvalidArgumentError("Invalid resource name: {}".format(first_request.resource_name))
 
             else:
-                raise InvalidArgumentError("Invalid resource name: {}".format(context.resource_name))
+                raise InvalidArgumentError("Invalid resource name: {}".format(first_request.resource_name))
 
             instance = self._get_instance(instance_name)
             return instance.write(requests)

buildgrid/server/cas/storage/remote.py

@@ -23,6 +23,8 @@ Forwwards storage requests to a remote storage.
 import io
 import logging
 
+import grpc
+
 from buildgrid.utils import gen_fetch_blob, gen_write_request_blob
 from buildgrid._protos.google.bytestream import bytestream_pb2_grpc
 from buildgrid._protos.build.bazel.remote.execution.v2 import remote_execution_pb2, remote_execution_pb2_grpc
@@ -44,8 +46,10 @@ class RemoteStorage(StorageABC):
         return False
 
     def get_blob(self, digest):
+        try:
             fetched_data = io.BytesIO()
             length = 0
+
             for data in gen_fetch_blob(self._stub_bs, digest, self._instance_name):
                 length += fetched_data.write(data)
 
@@ -57,6 +61,15 @@ class RemoteStorage(StorageABC):
             else:
                 return None
 
+        except grpc.RpcError as e:
+            if e.code() == grpc.StatusCode.NOT_FOUND:
+                pass
+            else:
+                self.logger.error(e.details())
+                raise
+
+        return None
+
     def begin_write(self, digest):
         return io.BytesIO(digest.SerializeToString())