ZTh ddlmZddlZddlmZddlZddlmZddl m Z ddl m Z ddl mZerddlmZddlZdd lmZdd lmZGd d e Zy) ) annotationsN) TYPE_CHECKING)ChannelsLowLevelClient)DataLowLevelClient) ResourceBase) cel_utils)datetime) SiftClient)ChannelceZdZdZd fd Z d dZddddddddddddddddd d dZddZddddd dd Zddddd dd Z xZ S)ChannelsAPIAsyncaHigh-level API for interacting with channels. This class provides a Pythonic, notebook-friendly interface for interacting with the ChannelsAPI. It handles automatic handling of gRPC services, seamless type conversion, and clear error handling. All methods in this class use the Channel class from the low-level wrapper, which is a user-friendly representation of a channel using standard Python data structures and types. ct||t|jj|_t |jj|_y)zdInitialize the ChannelsAPI. Args: sift_client: The Sift client to use. ) grpc_clientN)super__init__rclientr_low_level_clientr_data_low_level_client)self sift_client __class__s c/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_client/resources/channels.pyrzChannelsAPIAsync.__init__ s@ %!7DKKD[D[!\&8T[[E\E\&]#cxK|jj|d{}|j|S7w)zGet a Channel. Args: channel_id: The ID of the channel. Returns: The Channel. ) channel_idN)r get_channel_apply_client_to_instance)rrchannels rgetzChannelsAPIAsync.get*s;..::j:QQ--g66Rs :8:N)asset_idname name_contains name_regex descriptiondescription_containsactiverun_idrun_name client_keycreated_before created_aftermodified_beforemodified_afterorder_bylimitcJKtd|||fDdkDr tdtd||fDdkDr tdtd| | fDdkDr tdtd| |fDdkDr td g}|r%|jtjd ||r&|jtjd |nu|r&|jtj d |nM|rKt |tjr |j}|jtjd ||r&|jtjd |n'|r%|jtj d ||r%|jtjd ||r%|jtjd|| r%|jtjd| | r%|jtjd| | r%|jtjd| | r%|jtjd| | r%|jtjd| |r%|jtjd|dj|}|jj|||d{}|j!|S7w)a\List channels with optional filtering. Args: asset_id: The asset ID to get. name: The name of the channel to get. name_contains: The partial name of the channel to get. name_regex: The regex name of the channel to get. description: The description of the channel to get. description_contains: The partial description of the channel to get. active: Whether the channel is active. run_id: The run ID to get. run_name: The name of the run to get. client_key: The client key of the run to get. created_before: The created date of the channel to get. created_after: The created date of the channel to get. modified_before: The modified date of the channel to get. modified_after: The modified date of the channel to get. order_by: How to order the retrieved channels. limit: How many channels to retrieve. If None, retrieves all matches. Returns: A list of Channels that matches the filter. c32K|]}t|ywNbool.0xs r z)ChannelsAPIAsync.list_..eB1tAwBzBCannot provide more than one of name, name_contains, or name_regexc32K|]}t|ywr2r3r5s rr8z)ChannelsAPIAsync.list_..gsD1tAwDr:z8Cannot provide both description and description_containsc32K|]}t|ywr2r3r5s rr8z)ChannelsAPIAsync.list_..is@1tAw@r:z4Cannot provide both created_before and created_afterc32K|]}t|ywr2r3r5s rr8z)ChannelsAPIAsync.list_..kr9r:z6Cannot provide both modified_before and modified_afterr r!r$r&r'r(r) created_date modified_datez && ) query_filterr. max_resultsN)sum ValueErrorappendcelequalscontains isinstancerePatternpatternmatch less_than greater_thanjoinrlist_all_channels_apply_client_to_instances)rr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/ filter_parts filter_strchannelss rlist_zChannelsAPIAsync.list_:sV B}j AB BQ Fab b D.B CD Dq HWX X @ ?@ @1 DST T B. AB BQ FUV V     :x @ A     64 8 9     V] C D *bjj1'//    &* = >     =+ F G !    ]

rs<" TL4-!-6}E|}Er