o
    `j                     @   s   G d d dZ dS )c                   @   s,   e Zd ZdZdZedd Zedd ZdS )DescribeTransactionsdescribez6Describe one or more transactional ids (broker >= 3.0)c                 C   s   |j dtddddd d S )Nz--transactional-idappendtransactional_idsTz*Transactional id to describe (repeatable).)typeactiondestrequiredhelp)add_argumentstr)clsparser r   c/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/cli/admin/transactions/describe.pyadd_arguments   s
   
z"DescribeTransactions.add_argumentsc                 C   sb   | |j}i }| D ]"\}}| }|jj|d< tdd |jD dd d|d< |||< q|S )Nstatec                 S   s   g | ]	}|j |jd qS )topic	partitionr   ).0tpr   r   r   
<listcomp>   s    z0DescribeTransactions.command.<locals>.<listcomp>c                 S   s   | d | d fS )Nr   r   r   )pr   r   r   <lambda>   s    z.DescribeTransactions.command.<locals>.<lambda>)keytopic_partitions)describe_transactionsr   items_asdictr   valuesortedr   )r   clientargsresultsoutputtxn_iddescoutr   r   r   command   s   

zDescribeTransactions.commandN)__name__
__module____qualname__COMMANDHELPclassmethodr   r(   r   r   r   r   r      s    
r   N)r   r   r   r   r   <module>   s    