summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTristan van Berkom <tristan@codethink.co.uk>2020-12-21 17:08:15 +0900
committerTristan van Berkom <tristan@codethink.co.uk>2020-12-21 18:09:59 +0900
commit6a703cd32bea90fb57d5710b91e0310fa6116994 (patch)
tree350d5ba36d1f0ba7c113bf3db7f33d2c0b3077e9
parent0f658eee7b8130b047489fcd00958aa5e0d5d224 (diff)
downloadbuildstream-6a703cd32bea90fb57d5710b91e0310fa6116994.tar.gz
_assetcache.py: Remove private _message() function
Use Messenger convinence functions instead.
-rw-r--r--src/buildstream/_assetcache.py11
1 files changed, 1 insertions, 10 deletions
diff --git a/src/buildstream/_assetcache.py b/src/buildstream/_assetcache.py
index a0b502f2b..fef597af6 100644
--- a/src/buildstream/_assetcache.py
+++ b/src/buildstream/_assetcache.py
@@ -25,7 +25,6 @@ import grpc
from . import utils
from . import _yaml
from ._cas import CASRemote
-from ._message import Message, MessageType
from ._exceptions import AssetCacheError, LoadError, RemoteError
from ._remote import BaseRemote, RemoteSpec, RemoteType
from ._protos.build.bazel.remote.asset.v1 import remote_asset_pb2, remote_asset_pb2_grpc
@@ -573,14 +572,6 @@ class AssetCache:
return (index, storage)
- # _message()
- #
- # Local message propagator
- #
- def _message(self, message_type, message, **kwargs):
- args = dict(kwargs)
- self.context.messenger.message(Message(message_type, message, **args))
-
# _set_remotes():
#
# Set the list of remote caches. If project is None, the global list of
@@ -604,7 +595,7 @@ class AssetCache:
#
def _initialize_remotes(self):
def remote_failed(remote, error):
- self._message(MessageType.WARN, "Failed to initialize remote {}: {}".format(remote.url, error))
+ self.context.messenger.warn("Failed to initialize remote {}: {}".format(remote.url, error))
with self.context.messenger.timed_activity("Initializing remote caches", silent_nested=True):
self.initialize_remotes(on_failure=remote_failed)