diff options
author | Tristan van Berkom <tristan@codethink.co.uk> | 2020-12-21 17:08:15 +0900 |
---|---|---|
committer | Tristan van Berkom <tristan@codethink.co.uk> | 2020-12-21 18:09:59 +0900 |
commit | 6a703cd32bea90fb57d5710b91e0310fa6116994 (patch) | |
tree | 350d5ba36d1f0ba7c113bf3db7f33d2c0b3077e9 | |
parent | 0f658eee7b8130b047489fcd00958aa5e0d5d224 (diff) | |
download | buildstream-6a703cd32bea90fb57d5710b91e0310fa6116994.tar.gz |
_assetcache.py: Remove private _message() function
Use Messenger convinence functions instead.
-rw-r--r-- | src/buildstream/_assetcache.py | 11 |
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) |