diff options
Diffstat (limited to 'src/buildstream/_cas/casremote.py')
| -rw-r--r-- | src/buildstream/_cas/casremote.py | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/buildstream/_cas/casremote.py b/src/buildstream/_cas/casremote.py index 972c4d818..229fd4142 100644 --- a/src/buildstream/_cas/casremote.py +++ b/src/buildstream/_cas/casremote.py @@ -1,5 +1,4 @@ from collections import namedtuple -import io import os import multiprocessing import signal @@ -250,14 +249,10 @@ class CASRemote(): def push_message(self, message): message_buffer = message.SerializeToString() - message_digest = utils._message_digest(message_buffer) self.init() - with io.BytesIO(message_buffer) as b: - self._send_blob(message_digest, b) - - return message_digest + return self.cascache.add_object(buffer=message_buffer, instance_name=self.local_cas_instance_name) ################################################ # Local Private Methods # |