
    Vh                    >    d dl mZ d dlmZ d dlmZ  G d de      Zy)    )annotations)
ActionBase)
merge_hashc                  &     e Zd Zd Zd fd	Z xZS )ActionModulec                J    | j                  dd      }| j                  |      S )N	async_dirz~/.ansible_async)default)get_shell_option_remote_expand_user)selfr	   s     S/home/dcms/DCMS/lib/python3.12/site-packages/ansible/plugins/action/async_status.py_get_async_dirzActionModule._get_async_dir   s+     ))+?Q)R	''	22    c                   t         t        |   ||      }| j                  ddddddgddd      \  }}d	x|d
<   |d<   dx|d<   |d<   g x|d<   |d<   |d   }|d   }||d<   | j	                         }| j
                  j                  j                  ||      }	|dk(  r|	|d<   n
|	|d<   d|d
<   ||d<   t        || j                  d||            }|S )NstrT)typerequiredstatuscleanup)r   choicesr
   )jidmode)argument_specr   startedfinished stdoutstderrstdout_linesstderr_linesr   r   ansible_job_iderasedresults_file   
_async_dirzansible.legacy.async_status)module_name	task_varsmodule_args)
superr   runvalidate_argument_specr   _connection_shell	join_pathr   _execute_module)r   tmpr(   resultsvalidation_resultnew_module_argsr   r   r	   log_path	__class__s             r   r+   zActionModule.run   s8   d/Y?-1-H-H %48!&Hi3HU]^ .I .
*? 454	WZ0022GH-<>>'."9e$v&$' !'')	##**44YD9 (GH&.GN#!"GI(1%Wd&:&:Gdpy  HW&:  'X  Yr   )NN)__name__
__module____qualname__r   r+   __classcell__)r6   s   @r   r   r   
   s    3   r   r   N)
__future__r   ansible.plugins.actionr   ansible.utils.varsr   r    r   r   <module>r?      s    # - )): )r   