1111from armis_sdk .core .base_entity_client import BaseEntityClient
1212from armis_sdk .entities .collector_image import CollectorImage
1313from armis_sdk .entities .download_progress import DownloadProgress
14- from armis_sdk .enums .collector_image_type import CollectorImageType
14+ from armis_sdk .types .collector_image_type import CollectorImageType
1515
1616
1717@universalasync .wrap
@@ -26,7 +26,7 @@ class CollectorsClient(BaseEntityClient):
2626 async def download_image (
2727 self ,
2828 destination : Union [str , IO [bytes ]],
29- image_type : CollectorImageType = CollectorImageType . OVA ,
29+ image_type : CollectorImageType = " OVA" ,
3030 ) -> AsyncIterator [DownloadProgress ]:
3131 """Download a collector image to a specified destination path / file.
3232
@@ -71,15 +71,12 @@ async def main():
7171 async with client .stream ("GET" , collector_image .url ) as response :
7272 response .raise_for_status ()
7373 total_size = int (response .headers .get ("Content-Length" , "0" ))
74- # pylint: disable-next=contextmanager-generator-missing-cleanup
7574 with self .open_file (destination ) as file :
7675 async for chunk in response .aiter_bytes ():
7776 file .write (chunk )
7877 yield DownloadProgress (downloaded = file .tell (), total = total_size )
7978
80- async def get_image (
81- self , image_type : CollectorImageType = CollectorImageType .OVA
82- ) -> CollectorImage :
79+ async def get_image (self , image_type : CollectorImageType = "OVA" ) -> CollectorImage :
8380 """Get collector image information including download URL and credentials.
8481
8582 Args:
@@ -108,7 +105,7 @@ async def main():
108105 """
109106 async with self ._armis_client .client () as client :
110107 response = await client .get (
111- "/v3/collectors/_image" , params = {"image_type" : image_type . value }
108+ "/v3/collectors/_image" , params = {"image_type" : image_type }
112109 )
113110 data = response_utils .get_data_dict (response )
114111 return CollectorImage .model_validate (data )
0 commit comments