ZThddlmZddlmZmZddlmZddlmZddl m Z m Z ddl m Z erddlZddlmZdd lmZGd d eZy) ) annotations) TYPE_CHECKINGAny)AssetsLowLevelClient) ResourceBase)Asset AssetUpdate) cel_utilsN)datetime) SiftClientceZdZdZd fd Zddd ddZdddddddddddddddddd ddZdd Zdd dd Zdd Z xZ S)AssetsAPIAsyncaHigh-level API for interacting with assets. This class provides a Pythonic, notebook-friendly interface for interacting with the AssetsAPI. It handles automatic handling of gRPC services, seamless type conversion, and clear error handling. All methods in this class use the Asset class from the low-level wrapper, which is a user-friendly representation of an asset using standard Python data structures and types. cnt||t|jj|_y)zbInitialize the AssetsAPI. Args: sift_client: The Sift client to use. ) grpc_clientN)super__init__rclientr_low_level_client)self sift_client __class__s a/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_client/resources/assets.pyrzAssetsAPIAsync.__init__s) %!5$++BYBY!ZN)asset_idnamecK|r$|jj|d{}n|r|jjtjd|d{}t |dkrt d|dt |dkDrt dt |d|d|d }n t d |j|S77nw) zGet an Asset. Args: asset_id: The ID of the asset. name: The name of the asset. Returns: The Asset. Nr) query_filterzNo asset found with name '' Multiple (z) assets found with name 'rz(Either asset_id or name must be provided)r get_assetlist_all_assetsr equalslen ValueError_apply_client_to_instance)rrrassetassetss rgetzAssetsAPIAsync.get$s 00::8DDE 11AA&--fd;BF6{Q #=dV1!EFF6{Q  V -GvQO1IEGH H--e44#Es"!CC :CC A-C CF)r name_contains name_regex asset_ids created_aftercreated_beforemodified_aftermodified_before created_by modified_bytagstag_idsmetadatainclude_archived filter_queryorder_bylimitc2K|sg}|r%|jtjd||r%|jtjd||r%|jtjd||r%|jtj d||r%|jtj d||r%|jtjd||r%|jtj d||r%|jtjd|| rt| rt| r%|jtj d| | r%|jtj d| | rt|s$|jtjdtj|}|jj|||d {}|j|S7w) aList assets with optional filtering. Args: asset_ids: List of asset IDs to filter by. name: Exact name of the asset. name_contains: Partial name of the asset. name_regex: Regular expression string to filter assets by name. asset_ids: List of asset IDs to filter by. created_after: Created after this date. created_before: Created before this date. modified_after: Modified after this date. modified_before: Modified before this date. created_by: Assets created by this user. modified_by: Assets last modified by this user. tags: Assets with these tags. tag_ids: List of asset tag IDs to filter by. metadata: metadata filter include_archived: Include archived assets. filter_query: Explicit CEL query to filter assets. order_by: How to order the retrieved assets. # TODO: tooling for this? limit: How many assets to retrieve. If None, retrieves all matches. Returns: A list of Assets that matches the filter. rr created_date modified_datetag_namer4 archived_date)rr8 max_resultsN)appendr r#containsmatchin_ greater_than less_thanNotImplementedError equals_nulland_rr"_apply_client_to_instances)rrr*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9filtersr(s rlist_zAssetsAPIAsync.list_Gs^Gy//=>y11&-HIyvzBCy}}ZCDy55nmTUy22>>RSy55o~VWy22?OTU))))y}}Z>?y}}Y@A))#y44_EF$>>73L--==%>   ..v66  sG=H?HHcK|jdi|d{}t|dkDrtdt|dt|dk(r|dSy7>w)aFind a single asset matching the given query. Takes the same arguments as `list_`. If more than one asset is found, raises an error. Args: **kwargs: Keyword arguments to pass to `list_`. Returns: The Asset found or None. Nrr z) assets found for queryr)rKr$r%)rkwargsr(s rfindzAssetsAPIAsync.finds`"tzz+F++ v;?z#f+6NOP P [A !9  ,sAA?A archive_runscKt|tr|jxsdn|}|jj |xsd|d{|j |d{S77w)zArchive an asset. Args: asset: The Asset or asset ID to archive. archive_runs: If True, archive all Runs associated with the Asset. Returns: The archived Asset. rPN)r) isinstancerid_r delete_assetr))rr'rQrs rarchivezAssetsAPIAsync.archivesa'1&>599?E$$11(.b|1\\\XXxX000 ]0s$AA, A( A,#A*$A,*A,cKt|tr|jxsdn|}t|trt j |}||_|jj|d{}|j|S7w)zUpdate an Asset. Args: asset: The Asset or asset ID to update. update: Updates to apply to the Asset. Returns: The updated Asset. rS)updateN) rTrrUdictr model_validate resource_idr update_assetr&)rr'rYrs rrYzAssetsAPIAsync.updatesu'1&>599?E fd # //7F%,,999HH--e44IsA.B0B1B)rr )r str | Nonerr^returnr)$rr^r*r^r+zstr | re.Pattern | Noner,list[str] | Noner-datetime | Noner.rar/rar0rar1 Any | Noner2rbr3r`r4r`r5zlist[Any] | Noner6boolr7r^r8r^r9z int | Noner_z list[Asset])r_z Asset | None)r' str | AssetrQrcr_r)r'rdrYzAssetUpdate | dictr_r) __name__ __module__ __qualname____doc__rr)rKrOrWrY __classcell__)rs@rrrsR[ $ !5!5 !5  !5L $(.2&*)-*.*.+/!%"&!%$(%)!&#'# 'T7T7" T7 , T7 $ T7'T7(T7(T7)T7T7 T7T7"T7#T7 !T7"!#T7$%T7&'T7( )T7l"IN1 5rr) __future__rtypingrr/sift_client._internal.low_level_wrappers.assetsrsift_client.resources._basersift_client.sift_types.assetrr sift_client.utilr rer sift_client.clientr rrMrrrrs1"%P4;& !-}5\}5r