feat: cache individual assets on the snakemake side of the API

Author: johanneskoester

snakemake_interface_software_deployment_plugins/__init__.py

@@ -354,10 +354,9 @@ async def cache_asset(self, asset: str) -> None:
         """
         ...
 
-    async def managed_cache_assets(self) -> None:
+    async def managed_cache_asset(self, asset: str) -> None:
         try:
-            for asset in await self.get_cache_assets():
-                await self.cache_asset(asset)
+            await self.cache_asset(asset)
         except Exception as e:
             raise WorkflowError(f"Caching of {self.spec} failed: {e}") from e
 

snakemake_interface_software_deployment_plugins/tests.py

@@ -103,7 +103,11 @@ def test_cache(self, tmp_path):
 
         assert isinstance(env, CacheableEnvBase)
 
-        asyncio.run(env.cache_assets())
+        async def cache_assets():
+            for asset in env.get_cache_assets():
+                await env.managed_cache_asset(asset)
+
+        asyncio.run(cache_assets())
 
         self._deploy(env, tmp_path)