Review comments

Author: Pijukatel

pyproject.toml

@@ -36,7 +36,7 @@ keywords = [
 dependencies = [
     "apify-client>=2.0.0,<3.0.0",
     "apify-shared>=2.0.0,<3.0.0",
-    "crawlee @ git+https://github.com/apify/crawlee-python.git@master",
+    "crawlee==0.6.13b42",
     "cachetools>=5.5.0",
     "cryptography>=42.0.0",
     "impit>=0.6.1",

src/apify/_actor.py

@@ -341,7 +341,7 @@ async def init(self) -> None:
         await self.event_manager.__aenter__()
         self.log.debug('Event manager initialized')
 
-        await self.charging_manager_implementation.__aenter__()
+        await self._charging_manager_implementation.__aenter__()
         self.log.debug('Charging manager initialized')
 
         self._is_initialized = True
@@ -385,7 +385,7 @@ async def finalize() -> None:
                 await self.event_manager.wait_for_all_listeners_to_complete(timeout=event_listeners_timeout)
 
             await self.event_manager.__aexit__(None, None, None)
-            await self.charging_manager_implementation.__aexit__(None, None, None)
+            await self._charging_manager_implementation.__aexit__(None, None, None)
 
         await asyncio.wait_for(finalize(), cleanup_timeout.total_seconds())
         self._is_initialized = False
@@ -666,10 +666,10 @@ async def set_value(
     def get_charging_manager(self) -> ChargingManager:
         """Retrieve the charging manager to access granular pricing information."""
         self._raise_if_not_initialized()
-        return self.charging_manager_implementation
+        return self._charging_manager_implementation
 
     @cached_property
-    def charging_manager_implementation(self) -> ChargingManagerImplementation:
+    def _charging_manager_implementation(self) -> ChargingManagerImplementation:
         return ChargingManagerImplementation(self.configuration, self.apify_client)
 
     async def charge(self, event_name: str, count: int = 1) -> ChargeResult:

src/apify/storage_clients/_file_system/_storage_client.py

@@ -32,7 +32,10 @@ async def create_kvs_client(
     ) -> FileSystemKeyValueStoreClient:
         configuration = configuration or Configuration.get_global_configuration()
         client = await ApifyFileSystemKeyValueStoreClient.open(
-            id=id, name=name, alias=alias, configuration=configuration
+            id=id,
+            name=name,
+            alias=alias,
+            configuration=configuration,
         )
         await self._purge_if_needed(client, configuration)
         return client

tests/integration/actor_source_base/requirements.txt

@@ -1,4 +1,4 @@
 # The test fixture will put the Apify SDK wheel path on the next line
 APIFY_SDK_WHEEL_PLACEHOLDER
 uvicorn[standard]
-crawlee[parsel] @ git+https://github.com/apify/crawlee-python.git@master
+crawlee[parsel]==0.6.13b42