_basecache.py: Add release_resources() method

1 files changed, 10 insertions, 0 deletions

diff --git a/src/buildstream/_basecache.py b/src/buildstream/_basecache.py
index 46de29f7b..431a7304e 100644
--- a/src/buildstream/_basecache.py
+++ b/src/buildstream/_basecache.py
@@ -59,6 +59,16 @@ class BaseCache():
         self._has_fetch_remotes = False
         self._has_push_remotes = False
 
+    # release_resources():
+    #
+    # Release resources used by BaseCache.
+    #
+    def release_resources(self):
+        # Close all remotes and their gRPC channels
+        for project_remotes in self._remotes.values():
+            for remote in project_remotes:
+                remote.close()
+
     # specs_from_config_node()
     #
     # Parses the configuration of remote artifact caches from a config block.