File: //lib/python3.9/site-packages/ansible/plugins/action/__pycache__/async_status.cpython-39.pyc
a
�)g � @ sP d dl mZmZmZ eZd dlmZ d dlm Z d dl
m Z G dd� de �Z dS )� )�absolute_import�division�print_function)�AnsibleActionFail)�
ActionBase)�
merge_hashc s& e Zd Zdd� Zd� fdd� Z� ZS )� ActionModulec C s | j ddd�}| �|�S )N� async_dirz~/.ansible_async)�default)Zget_shell_optionZ_remote_expand_user)�selfr � r �G/usr/lib/python3.9/site-packages/ansible/plugins/action/async_status.py�_get_async_dir s zActionModule._get_async_dirNc
s� t t| ��||�}| jddd�dddgdd�d�d�\}}d |d
< |d < d |d
< |d< g |d< |d< |d }|d }||d< | �� }| jj�||�} |dkr�| |d< n| |d< d|d
< ||d< t|| j d||d��}|S )N�strT)�type�required�statusZcleanup)r �choicesr
)�jid�mode)Z
argument_specr �started�finished� �stdout�stderrZ stdout_linesZ stderr_linesr r Zansible_job_idZerasedZ results_file� Z
_async_dirzansible.legacy.async_status)Z module_name� task_varsZ module_args)
�superr �runZvalidate_argument_specr Z _connectionZ_shellZ join_pathr Z_execute_module)
r �tmpr �resultsZvalidation_resultZnew_module_argsr r r Zlog_path�� __class__r r
r s* ��
zActionModule.run)NN)�__name__�
__module__� __qualname__r r �
__classcell__r r r! r
r s r N)
Z
__future__r r r r Z
__metaclass__Zansible.errorsr Zansible.plugins.actionr Zansible.utils.varsr r r r r r
�<module> s