Fix integration test and Not implemented exception in purge

Author: vdusek

src/apify/storage_clients/_apify/_dataset_client.py

@@ -129,10 +129,10 @@ async def open(
 
     @override
     async def purge(self) -> None:
-        # TODO: better?
-        # https://github.com/apify/apify-sdk-python/issues/469
-        async with self._lock:
-            await self._api_client.delete()
+        raise NotImplementedError(
+            'Purging datasets is not supported in the Apify platform. '
+            'Use the `drop` method to delete the dataset instead.'
+        )
 
     @override
     async def drop(self) -> None:

src/apify/storage_clients/_apify/_key_value_store_client.py

@@ -130,10 +130,10 @@ async def open(
 
     @override
     async def purge(self) -> None:
-        # TODO: better?
-        # https://github.com/apify/apify-sdk-python/issues/469
-        async with self._lock:
-            await self._api_client.delete()
+        raise NotImplementedError(
+            'Purging key-value stores is not supported in the Apify platform. '
+            'Use the `drop` method to delete the key-value store instead.'
+        )
 
     @override
     async def drop(self) -> None:

src/apify/storage_clients/_apify/_request_queue_client.py

@@ -166,10 +166,10 @@ async def open(
 
     @override
     async def purge(self) -> None:
-        # TODO: better?
-        # https://github.com/apify/apify-sdk-python/issues/469
-        async with self._lock:
-            await self._api_client.delete()
+        raise NotImplementedError(
+            'Purging the request queue is not supported in the Apify platform. '
+            'Use the `drop` method to delete the request queue instead.'
+        )
 
     @override
     async def drop(self) -> None:

tests/integration/test_actor_api_helpers.py

@@ -46,9 +46,6 @@ async def main() -> None:
             assert len(env_dict.get('actor_id', '')) == 17
             assert len(env_dict.get('actor_run_id', '')) == 17
             assert len(env_dict.get('user_id', '')) == 17
-            assert len(env_dict.get('default_dataset_id', '')) == 17
-            assert len(env_dict.get('default_key_value_store_id', '')) == 17
-            assert len(env_dict.get('default_request_queue_id', '')) == 17
 
     actor = await make_actor(label='get-env', main_func=main)
     run_result = await run_actor(actor)