Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 16 additions & 1 deletion src/codeocean/data_asset.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
from dataclasses import dataclass
from requests_toolbelt.sessions import BaseUrlSession
from time import sleep, time
from typing import Optional
from typing import Optional, Iterator

from codeocean.components import Ownership, SortOrder, SearchFilter, Permissions
from codeocean.computation import PipelineProcess, Param
Expand Down Expand Up @@ -309,6 +309,21 @@ def search_data_assets(self, search_params: DataAssetSearchParams) -> DataAssetS

return DataAssetSearchResults.from_dict(res.json())

def search_data_assets_iterator(self, search_params: DataAssetSearchParams) -> Iterator[DataAsset]:
params = search_params.to_dict()
while True:
response = self.search_data_assets(
search_params=DataAssetSearchParams(**params)
)

for result in response.results:
yield result

if not response.has_more:
return

params["next_token"] = response.next_token

def list_data_asset_files(self, data_asset_id: str, path: str = "") -> Folder:
data = {
"path": path,
Expand Down