
    ZTh9                     d    d Z ddlZddlmZ  G d de      Z G d de      Zd Z G d	 d
e      Z	y)zEClient and server classes corresponding to protobuf-defined services.    N)runs_pb2c                       e Zd ZdZd Zy)RunServiceStub8Missing associated documentation comment in .proto file.c                    |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                  j                  t        j                  j
                        | _	        |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                   j                  t        j"                  j
                        | _        |j                  dt        j&                  j                  t        j(                  j
                        | _        |j                  dt        j,                  j                  t        j.                  j
                        | _        |j                  d	t        j2                  j                  t        j4                  j
                        | _        y
)zIConstructor.

        Args:
            channel: A grpc.Channel.
        /sift.runs.v2.RunService/GetRun)request_serializerresponse_deserializer!/sift.runs.v2.RunService/ListRuns"/sift.runs.v2.RunService/CreateRun'/sift.runs.v2.RunService/CreateAdhocRun"/sift.runs.v2.RunService/UpdateRun"/sift.runs.v2.RunService/DeleteRun /sift.runs.v2.RunService/StopRun?/sift.runs.v2.RunService/CreateAutomaticRunAssociationForAssetsN)unary_unary"sift_dot_runs_dot_v2_dot_runs__pb2GetRunRequestSerializeToStringGetRunResponse
FromStringGetRunListRunsRequestListRunsResponseListRunsCreateRunRequestCreateRunResponse	CreateRunCreateAdhocRunRequestCreateAdhocRunResponseCreateAdhocRunUpdateRunRequestUpdateRunResponse	UpdateRunDeleteRunRequestDeleteRunResponse	DeleteRunStopRunRequestStopRunResponseStopRun-CreateAutomaticRunAssociationForAssetsRequest.CreateAutomaticRunAssociationForAssetsResponse&CreateAutomaticRunAssociationForAssets)selfchannels     _/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift/runs/v2/runs_pb2_grpc.py__init__zRunServiceStub.__init__   s    ))1#E#S#S#e#e&H&W&W&b&b * 
  ++3#E#U#U#g#g&H&Y&Y&d&d , 
 !,,4#E#V#V#h#h&H&Z&Z&e&e - 
 &119#E#[#[#m#m&H&_&_&j&j 2 
 !,,4#E#V#V#h#h&H&Z&Z&e&e - 
 !,,4#E#V#V#h#h&H&Z&Z&e&e - 
 **2#E#T#T#f#f&H&X&X&c&c + 
 7>6I6IQ#E#s#s  $F  $F&H&w&w  'C  'C 7J 73    N)__name__
__module____qualname____doc__r1    r2   r0   r   r      s
    B-r2   r   c                   @    e Zd ZdZd Zd Zd Zd Zd Zd Z	d Z
d	 Zy
)RunServiceServicerr   c                     |j                  t        j                  j                         |j	                  d       t        d      )zRetrieve a run.
        Method not implemented!set_codegrpc
StatusCodeUNIMPLEMENTEDset_detailsNotImplementedErrorr.   requestcontexts      r0   r   zRunServiceServicer.GetRun>   7     	66756!";<<r2   c                     |j                  t        j                  j                         |j	                  d       t        d      )z0Retrieve runs using an optional filter.
        r;   r<   rC   s      r0   r   zRunServiceServicer.ListRunsE   rF   r2   c                     |j                  t        j                  j                         |j	                  d       t        d      )zCreate a run.
        r;   r<   rC   s      r0   r   zRunServiceServicer.CreateRunL   rF   r2   c                     |j                  t        j                  j                         |j	                  d       t        d      )zXCreate adhoc run, this is used to create a run after the data has been ingested
        r;   r<   rC   s      r0   r!   z!RunServiceServicer.CreateAdhocRunS   rF   r2   c                     |j                  t        j                  j                         |j	                  d       t        d      )z[Updates an existing run using using the list of fields specified in `update_mask`.
        r;   r<   rC   s      r0   r$   zRunServiceServicer.UpdateRunZ   rF   r2   c                     |j                  t        j                  j                         |j	                  d       t        d      )ziPermanently delete a given run. In order for a run to be deleted it must have a set `stop_time`.
        r;   r<   rC   s      r0   r'   zRunServiceServicer.DeleteRuna   rF   r2   c                     |j                  t        j                  j                         |j	                  d       t        d      )z|Set the stop time of a run to the current time. To set the stop time of a run to an arbitrary time see `UpdateRun`.
        r;   r<   rC   s      r0   r*   zRunServiceServicer.StopRunh   rF   r2   c                     |j                  t        j                  j                         |j	                  d       t        d      )z6Associates a list of assets with a given run.
        r;   r<   rC   s      r0   r-   z9RunServiceServicer.CreateAutomaticRunAssociationForAssetso   rF   r2   N)r3   r4   r5   r6   r   r   r   r!   r$   r'   r*   r-   r7   r2   r0   r9   r9   ;   s-    B========r2   r9   c                 j   t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                   j                        t        j                  | j"                  t        j$                  j
                  t        j&                  j                        t        j                  | j(                  t        j*                  j
                  t        j,                  j                        t        j                  | j.                  t        j0                  j
                  t        j2                  j                        t        j                  | j4                  t        j6                  j
                  t        j8                  j                        d}t        j:                  d|      }|j=                  |f       y )N)request_deserializerresponse_serializer)r   r   r   r!   r$   r'   r*   r-   zsift.runs.v2.RunService)r>   unary_unary_rpc_method_handlerr   r   r   r   r   r   r   r   r   r   r   r   r!   r   r    r$   r"   r#   r'   r%   r&   r*   r(   r)   r-   r+   r,   method_handlers_generic_handleradd_generic_rpc_handlers)servicerserverrpc_method_handlersgeneric_handlers       r0    add_RunServiceServicer_to_serverrX   w   s   99OO)K)Y)Y)d)d(J(Y(Y(k(k
 ;;%%)K)[)[)f)f(J([([(m(m
 <<&&)K)\)\)g)g(J(\(\(n(n
 #AA++)K)a)a)l)l(J(a(a(s(s
 <<&&)K)\)\)g)g(J(\(\(n(n
 <<&&)K)\)\)g)g(J(\(\(n(n
 ::$$)K)Z)Z)e)e(J(Z(Z(l(l
 7;6Y6YCC)K)y)y  *E  *E(J(y(y  )L  )L7I)T ::%':<O
##_$67r2   c                       e Zd ZdZe	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Z	e	 	 	 	 	 	 	 	 dd       Z
e	 	 	 	 	 	 	 	 dd	       Ze	 	 	 	 	 	 	 	 dd
       Zy)
RunServicer   Nc
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   experimentalr   r   r   r   r   r   
rD   targetoptionschannel_credentialscall_credentialsinsecurecompressionwait_for_readytimeoutmetadatas
             r0   r   zRunService.GetRun   sX       ,,Wf>_.<<NN.==HH(&^Wh	X 	Xr2   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   r\   r   r   r   r   r   r   r]   s
             r0   r   zRunService.ListRuns   sX       ,,Wf>a.>>PP.??JJ(&^Wh	X 	Xr2   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   r\   r   r   r   r   r   r   r]   s
             r0   r   zRunService.CreateRun   X       ,,Wf>b.??QQ.@@KK(&^Wh	X 	Xr2   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   r\   r   r   r   r   r    r   r]   s
             r0   r!   zRunService.CreateAdhocRun   sX       ,,Wf>g.DDVV.EEPP(&^Wh	X 	Xr2   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   r\   r   r   r"   r   r#   r   r]   s
             r0   r$   zRunService.UpdateRun   ri   r2   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   r\   r   r   r%   r   r&   r   r]   s
             r0   r'   zRunService.DeleteRun   ri   r2   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   r\   r   r   r(   r   r)   r   r]   s
             r0   r*   zRunService.StopRun  sX       ,,Wf>`.==OO.>>II(&^Wh	X 	Xr2   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r>   r\   r   r   r+   r   r,   r   r]   s
             r0   r-   z1RunService.CreateAutomaticRunAssociationForAssets"  sX       ,,Wf>.\\nn.]]hh(&^Wh	X 	Xr2   )r7   NNFNNNN)r3   r4   r5   r6   staticmethodr   r   r   r!   r$   r'   r*   r-   r7   r2   r0   rZ   rZ      s   B  $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X Xr2   rZ   )
r6   r>   sift.runs.v2r   r   objectr   r9   rX   rZ   r7   r2   r0   <module>rr      s>    K  G0V 0f9= 9=x-8bIX IXr2   