
    Ch9                    *   S SK Jr  S SKrS SKrS SKJr  S SKJrJr  S SKJ	r	J
r
JrJrJr  S SKrS SKJr  SSKJrJr  / S	Qr\" S
5      rSS jrSSS jjrSSS jjrSS jr    SS jrSS jr\" \R:                  R=                  S5      5      rSr Sr!g)    )annotationsN)AbstractEventLoop)	Awaitable	Coroutine)AnyOptionalTypeVarUnioncast)Version   )OffsetAndMetadataTopicPartition)create_taskcreate_futureNO_EXTENSIONSINTEGER_MAX_VALUEINTEGER_MIN_VALUETc                8    [        5       nUR                  U 5      $ N)get_running_loopr   )coroloops     RC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/util.pyr   r       s    DD!!    c                <    U c
  [        5       n U R                  5       $ r   )r   r   r   s    r   r   r   %   s    |!r   c                   #    [         R                  " U5       IS h  vN   U I S h  vN sS S S 5      IS h  vN   $  N N N	! , IS h  vN  (       d  f       g = f7fr   )async_timeouttimeout)futr!   s     r   wait_forr#   +   s9      $$W--y .-- .---sN   A=AA?AAAAAAA	A
AAc                    [        U 5      R                  nS[        U5      s=::  a  S::  d  O  [        U 5      e[	        [
        [        [        [        4   / UQSP7S S 5      nSUs=::  a  S:  d  O  [        U 5      eU$ )N      r   )r   	   )r&   r   )r   releaselen
ValueErrorr   tupleint)api_versionparsedversions      r   parse_kafka_versionr0   2   sq    [!))FF q %%5c3'61bq)9:GW%v%%%Nr   c                   U (       a  [        U [        5      (       d  [        U 5      e0 nU R                  5        Hp  u  p#[        U[        5      (       d  [        S5      e[        U[        5      (       a  USpTO% Uu  pE[        U[        5      (       d  [        S5      e[        XE5      X'   Mr     U$ ! [         a  n[        U 5      UeS nAff = f)Nz%Key should be TopicPartition instance zMetadata should be a string)

isinstancedictr*   itemsr   	TypeErrorr,   	Exceptionstrr   )offsetsformatted_offsetstpoffset_and_metadataoffsetmetadataexcs          r   commit_structure_validater@   =   s     *Wd33!!#*==?"n--CDD)3//2BH3#6  h,, =>> 1& C $3    3 )s23s   9B00
C:CCc                 p    [         R                  " 5       n U R                  5       (       d  [        S5      eU $ )NzOThe object should be created within an async function or provide loop directly.)asyncioget_event_loop
is_runningRuntimeErrorr   s    r   r   r   X   s6    !!#D??%
 	
 Kr   AIOKAFKA_NO_EXTENSIONSii   )r   zCoroutine[Any, Any, T]returnzasyncio.Task[T]r   )r   zOptional[AbstractEventLoop]rG   zasyncio.Future[T])r"   zAwaitable[T]r!   zUnion[None, int, float]rG   r   )r-   r8   rG   ztuple[int, int, int])r9   zDdict[TopicPartition, Union[int, tuple[int, str], OffsetAndMetadata]]rG   z'dict[TopicPartition, OffsetAndMetadata])rG   zasyncio.AbstractEventLoop)"
__future__r   rB   osr   collections.abcr   r   typingr   r   r	   r
   r   r    packaging.versionr   structsr   r   __all__r   r   r   r#   r0   r@   r   boolenvirongetr   r   r    r   r   <module>rS      s    "  	 % 0   % 6 CL"
 Q,6 RZZ^^$<=>  r   