Skip to content

Commit bf0b75c

Browse files
committed
Re-order methods
1 parent b00d2b9 commit bf0b75c

File tree

4 files changed

+13
-13
lines changed

4 files changed

+13
-13
lines changed

src/apify/storage_clients/_apify/_dataset_client.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -263,9 +263,6 @@ class DatasetApiClientFactory(ApiClientFactory[DatasetClientAsync, DatasetMetada
263263
def _collection_client(self) -> DatasetCollectionClientAsync:
264264
return self._api_client.datasets()
265265

266-
def _get_resource_client(self, id: str) -> DatasetClientAsync:
267-
return self._api_client.dataset(dataset_id=id)
268-
269266
@property
270267
def _default_id(self) -> str | None:
271268
return self._configuration.default_dataset_id
@@ -277,3 +274,6 @@ def _storage_type(self) -> type[Dataset]:
277274
@staticmethod
278275
def _get_metadata(raw_metadata: dict | None) -> DatasetMetadata:
279276
return DatasetMetadata.model_validate(raw_metadata)
277+
278+
def _get_resource_client(self, id: str) -> DatasetClientAsync:
279+
return self._api_client.dataset(dataset_id=id)

src/apify/storage_clients/_apify/_key_value_store_client.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -189,9 +189,6 @@ class KvsApiClientFactory(ApiClientFactory[KeyValueStoreClientAsync, ApifyKeyVal
189189
def _collection_client(self) -> KeyValueStoreCollectionClientAsync:
190190
return self._api_client.key_value_stores()
191191

192-
def _get_resource_client(self, id: str) -> KeyValueStoreClientAsync:
193-
return self._api_client.key_value_store(key_value_store_id=id)
194-
195192
@property
196193
def _default_id(self) -> str | None:
197194
return self._configuration.default_key_value_store_id
@@ -203,3 +200,6 @@ def _storage_type(self) -> type[KeyValueStore]:
203200
@staticmethod
204201
def _get_metadata(raw_metadata: dict | None) -> ApifyKeyValueStoreMetadata:
205202
return ApifyKeyValueStoreMetadata.model_validate(raw_metadata)
203+
204+
def _get_resource_client(self, id: str) -> KeyValueStoreClientAsync:
205+
return self._api_client.key_value_store(key_value_store_id=id)

src/apify/storage_clients/_apify/_request_queue_client.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -250,9 +250,6 @@ class RqApiClientFactory(ApiClientFactory[RequestQueueClientAsync, ApifyRequestQ
250250
def _collection_client(self) -> RequestQueueCollectionClientAsync:
251251
return self._api_client.request_queues()
252252

253-
def _get_resource_client(self, id: str) -> RequestQueueClientAsync:
254-
return self._api_client.request_queue(request_queue_id=id)
255-
256253
@property
257254
def _default_id(self) -> str | None:
258255
return self._configuration.default_request_queue_id
@@ -264,3 +261,6 @@ def _storage_type(self) -> type[RequestQueue]:
264261
@staticmethod
265262
def _get_metadata(raw_metadata: dict | None) -> ApifyRequestQueueMetadata:
266263
return ApifyRequestQueueMetadata.model_validate(raw_metadata)
264+
265+
def _get_resource_client(self, id: str) -> RequestQueueClientAsync:
266+
return self._api_client.request_queue(request_queue_id=id)

src/apify/storage_clients/_apify/_utils.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -303,10 +303,6 @@ def _default_id(self) -> str | None:
303303
def _storage_type(self) -> type[Storage]:
304304
"""Get a metadata model class."""
305305

306-
@abstractmethod
307-
def _get_resource_client(self, id: str) -> TResourceClient:
308-
"""Get a resource API client."""
309-
310306
@staticmethod
311307
@abstractmethod
312308
def _get_metadata(raw_metadata: dict | None) -> TStorageMetadata:
@@ -338,3 +334,7 @@ async def _open_by_alias(self, alias: str) -> tuple[TResourceClient, TStorageMet
338334
# Return the client for the newly created storage directly.
339335
# It was just created, no need to refetch it.
340336
return self._get_resource_client(id=metadata.id), self._get_metadata(raw_metadata)
337+
338+
@abstractmethod
339+
def _get_resource_client(self, id: str) -> TResourceClient:
340+
"""Get a resource API client."""

0 commit comments

Comments
 (0)