Do not attempt to deal with limited retention for alias storages locally

Author: Pijukatel

src/apify/storage_clients/_apify/_storage_client.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+import logging
 from asyncio import Lock
 from typing import TYPE_CHECKING
 
@@ -118,6 +119,13 @@ async def _initialize_alias_storages(cls) -> None:
         This method is called once to populate storage_instance_manager alias related cache. All existing alias
         storages are saved in storage_instance_manager cache. If the alias storage is not there, it does not exist yet.
         """
+        if not Configuration.get_global_configuration().is_at_home:
+            logging.getLogger(__name__).warning(
+                'Alias storage limited retention is only supported on Apify platform. '
+                'No pre-existing storages are imported.'
+            )
+            return
+
         async with cls.get_alias_init_lock():
             if cls._alias_storages_initialized:
                 return

src/apify/storage_clients/_apify/_utils.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
 import base64
+import logging
 from logging import getLogger
 from typing import TYPE_CHECKING
 
@@ -89,6 +90,12 @@ def _create_fernet(token: str) -> Fernet:
         return Fernet(base64.urlsafe_b64encode(token_32))
 
     async def store_mapping_to_apify_kvs(self, storage_id: str) -> None:
+        if not Configuration.get_global_configuration().is_at_home:
+            logging.getLogger(__name__).warning(
+                'Alias storage limited retention is only supported on Apify platform. Storage is not exported.'
+            )
+            return
+
         default_kvs_client = await self.get_default_kvs_client()
         await default_kvs_client.get()