casremote.py: Use add_object() in push_message()

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            #