diff --git a/src/apify/storage_clients/_apify/_dataset_client.py b/src/apify/storage_clients/_apify/_dataset_client.py index 6a30bfbc..9c6408fc 100644 --- a/src/apify/storage_clients/_apify/_dataset_client.py +++ b/src/apify/storage_clients/_apify/_dataset_client.py @@ -147,15 +147,6 @@ async def open( # Fetch its metadata. metadata = await apify_dataset_client.get() - # If metadata is None, it means the storage does not exist, so we create it. - if metadata is None: - id = DatasetMetadata.model_validate( - await apify_datasets_client.get_or_create(), - ).id - apify_dataset_client = apify_client_async.dataset(dataset_id=id) - - # Verify that the storage exists by fetching its metadata again. - metadata = await apify_dataset_client.get() if metadata is None: raise ValueError(f'Opening dataset with id={id}, name={name}, and alias={alias} failed.') diff --git a/src/apify/storage_clients/_apify/_key_value_store_client.py b/src/apify/storage_clients/_apify/_key_value_store_client.py index 8d698a80..e2b58333 100644 --- a/src/apify/storage_clients/_apify/_key_value_store_client.py +++ b/src/apify/storage_clients/_apify/_key_value_store_client.py @@ -137,15 +137,6 @@ async def open( # Fetch its metadata. metadata = await apify_kvs_client.get() - # If metadata is None, it means the storage does not exist, so we create it. - if metadata is None: - id = ApifyKeyValueStoreMetadata.model_validate( - await apify_kvss_client.get_or_create(), - ).id - apify_kvs_client = apify_client_async.key_value_store(key_value_store_id=id) - - # Verify that the storage exists by fetching its metadata again. - metadata = await apify_kvs_client.get() if metadata is None: raise ValueError(f'Opening key-value store with id={id}, name={name}, and alias={alias} failed.') diff --git a/src/apify/storage_clients/_apify/_request_queue_client.py b/src/apify/storage_clients/_apify/_request_queue_client.py index 74c48cde..97fcf4f8 100644 --- a/src/apify/storage_clients/_apify/_request_queue_client.py +++ b/src/apify/storage_clients/_apify/_request_queue_client.py @@ -276,15 +276,6 @@ async def open( # Fetch its metadata. metadata = await apify_rq_client.get() - # If metadata is None, it means the storage does not exist, so we create it. - if metadata is None: - id = RequestQueueMetadata.model_validate( - await apify_rqs_client.get_or_create(), - ).id - apify_rq_client = apify_client_async.request_queue(request_queue_id=id, client_key=client_key) - - # Verify that the storage exists by fetching its metadata again. - metadata = await apify_rq_client.get() if metadata is None: raise ValueError(f'Opening request queue with id={id}, name={name}, and alias={alias} failed.')