
    ZThk                     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)jobs_pb2c                       e Zd ZdZd Zy)JobServiceStub8Missing associated documentation comment in .proto file.c                 (   |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                  j                  t        j                  j
                        | _	        y)zIConstructor.

        Args:
            channel: A grpc.Channel.
        !/sift.jobs.v1.JobService/ListJobs)request_serializerresponse_deserializer"/sift.jobs.v1.JobService/CancelJobN)
unary_unary"sift_dot_jobs_dot_v1_dot_jobs__pb2ListJobsRequestSerializeToStringListJobsResponse
FromStringListJobsCancelJobRequestCancelJobResponse	CancelJob)selfchannels     _/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift/jobs/v1/jobs_pb2_grpc.py__init__zJobServiceStub.__init__   sv      ++3#E#U#U#g#g&H&Y&Y&d&d , 
 !,,4#E#V#V#h#h&H&Z&Z&e&e -     N)__name__
__module____qualname____doc__r    r   r   r   r      s
    Br   r   c                       e Zd ZdZd Zd Zy)JobServiceServicerr   c                     |j                  t        j                  j                         |j	                  d       t        d      )zList jobs.
        Method not implemented!set_codegrpc
StatusCodeUNIMPLEMENTEDset_detailsNotImplementedErrorr   requestcontexts      r   r   zJobServiceServicer.ListJobs    s7     	66756!";<<r   c                     |j                  t        j                  j                         |j	                  d       t        d      )a5  Requests cancellation of an active job. If the job hasn't started yet, it will be cancelled immediately.
        Jobs that are already finished, failed, or cancelled are not affected.
        Cancelled jobs have implementation-based behavior, but in every case it's valid to cancel a job at any time.
        r#   r$   r+   s      r   r   zJobServiceServicer.CancelJob'   s7    
 	66756!";<<r   N)r   r   r   r   r   r   r   r   r   r!   r!      s    B==r   r!   c                    t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        d}t        j                  d|      }|j                  |f       y )N)request_deserializerresponse_serializer)r   r   zsift.jobs.v1.JobService)r&   unary_unary_rpc_method_handlerr   r   r   r   r   r   r   r   r   method_handlers_generic_handleradd_generic_rpc_handlers)servicerserverrpc_method_handlersgeneric_handlers       r    add_JobServiceServicer_to_serverr9   1   s    ;;%%)K)[)[)f)f(J([([(m(m
 <<&&)K)\)\)g)g(J(\(\(n(n ::%':<O
##_$67r   c                   T    e Zd ZdZe	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Zy)
JobServicer   Nc
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r&   experimentalr   r   r   r   r   r   
r,   targetoptionschannel_credentialscall_credentialsinsecurecompressionwait_for_readytimeoutmetadatas
             r   r   zJobService.ListJobsG   sX       ,,Wf>a.>>PP.??JJ(&^Wh	X 	Xr   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )r&   r=   r   r   r   r   r   r   r>   s
             r   r   zJobService.CancelJobX   sX       ,,Wf>b.??QQ.@@KK(&^Wh	X 	Xr   )r   NNFNNNN)r   r   r   r   staticmethodr   r   r   r   r   r;   r;   D   sc    B  $!X X    $!X Xr   r;   )
r   r&   sift.jobs.v1r   r   objectr   r!   r9   r;   r   r   r   <module>rL      s9    K  GV *= =(8&#X #Xr   