Add error hint when opening non-existent local storage

Author: Pijukatel

src/apify/_actor.py

@@ -65,7 +65,9 @@ async def wrapper(
             return await function(self=self, id=id, name=name, force_cloud=force_cloud)
         except Exception as e:
             if not force_cloud:
-                e.args = (f'{e.args[0]} (If you are trying to retrieve a remote storage, use `force_cloud=True`.)',)
+                e.args = (
+                    f'{e.args[0]} (If you are trying to retrieve a remote storage, use `force_cloud=True` argument.)',
+                )
             raise
 
     return cast(TFun, wrapper)

tests/unit/actor/test_actor_dataset.py

@@ -62,3 +62,12 @@ async def test_push_data_to_dataset() -> None:
 
         list_page = await dataset.get_data(limit=desired_item_count)
         assert {item['id'] for item in list_page.items} == set(range(desired_item_count))
+
+
+async def test_open_local_non_existent_dataset() -> None:
+    async with Actor as my_actor:
+        with pytest.raises(RuntimeError) as e:
+            await my_actor.open_dataset(id='non-existent')
+        assert str(e.value).endswith(
+            'If you are trying to retrieve a remote storage, use `force_cloud=True` argument.)'
+        )

tests/unit/actor/test_actor_key_value_store.py

@@ -92,3 +92,12 @@ async def test_get_input_with_encrypted_secrets(
         input = await my_actor.get_input()  # noqa: A001
         assert input['foo'] == input_with_secret['foo']
         assert input['secret'] == secret_string
+
+
+async def test_open_local_non_existent_kvs() -> None:
+    async with Actor as my_actor:
+        with pytest.raises(RuntimeError) as e:
+            await my_actor.open_key_value_store(id='non-existent')
+        assert str(e.value).endswith(
+            'If you are trying to retrieve a remote storage, use `force_cloud=True` argument.)'
+        )

tests/unit/actor/test_actor_request_queue.py

@@ -27,3 +27,12 @@ async def test_open_returns_same_references() -> None:
         rq_by_id_2 = await Actor.open_key_value_store(id=rq_by_name_1._id)
         assert rq_by_id_1 is rq_by_name_1
         assert rq_by_id_2 is rq_by_id_1
+
+
+async def test_open_local_non_existent_rq() -> None:
+    async with Actor as my_actor:
+        with pytest.raises(RuntimeError) as e:
+            await my_actor.open_request_queue(id='non-existent')
+        assert str(e.value).endswith(
+            'If you are trying to retrieve a remote storage, use `force_cloud=True` argument.)'
+        )