File tree Expand file tree Collapse file tree 4 files changed +3
-11
lines changed Expand file tree Collapse file tree 4 files changed +3
-11
lines changed Original file line number Diff line number Diff line change @@ -301,7 +301,7 @@ async def init(self) -> None:
301301
302302 # Create an instance of the cloud storage client, the local storage client is obtained
303303 # from the service locator
304- self ._cloud_storage_client = ApifyStorageClient (configuration = self . configuration )
304+ self ._cloud_storage_client = ApifyStorageClient ()
305305
306306 # Make sure that the currently initialized instance is also available through the global `Actor` proxy
307307 cast ('Proxy' , Actor ).__wrapped__ = self
Original file line number Diff line number Diff line change @@ -56,6 +56,7 @@ async def open_kvs() -> KeyValueStore:
5656 storage_client = ApifyStorageClient ()
5757 return await KeyValueStore .open (
5858 name = kvs_name ,
59+ configuration = configuration ,
5960 storage_client = storage_client ,
6061 )
6162 return await KeyValueStore .open (name = kvs_name )
Original file line number Diff line number Diff line change @@ -53,6 +53,7 @@ async def open_rq() -> RequestQueue:
5353 if configuration .is_at_home :
5454 storage_client = ApifyStorageClient ()
5555 return await RequestQueue .open (
56+ configuration = configuration ,
5657 storage_client = storage_client ,
5758 )
5859 return await RequestQueue .open ()
Original file line number Diff line number Diff line change 44
55from typing_extensions import override
66
7- from crawlee import service_locator
87from crawlee .storage_clients ._base import StorageClient
98
109from ._dataset_client import ApifyDatasetClient
2019class ApifyStorageClient (StorageClient ):
2120 """Apify storage client."""
2221
23- def __init__ (self , configuration : Configuration | None = None ) -> None :
24- """Initialize the file system storage client.
25-
26- Args:
27- configuration: Optional configuration instance to use with the storage client.
28- If not provided, the global configuration will be used.
29- """
30- self ._configuration = configuration or service_locator .get_configuration ()
31-
3222 @override
3323 async def create_dataset_client (
3424 self ,
You can’t perform that action at this time.
0 commit comments