a )g @sPddlmZmZmZeZddlmZddlm Z ddl m Z Gddde Z dS))absolute_importdivisionprint_function)AnsibleActionFail) ActionBase) merge_hashcs&eZdZddZdfdd ZZS) ActionModulecCs|jddd}||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_dirszActionModule._get_async_dirNc stt|||}|jddddddgdddd\}}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)NstrT)typerequiredstatusZcleanup)rchoicesr )jidmode)Z argument_specrstartedfinishedstdoutstderrZ stdout_linesZ stderr_linesrrZansible_job_idZerasedZ results_fileZ _async_dirzansible.legacy.async_status)Z module_name task_varsZ module_args) superrrunZvalidate_argument_specrZ _connectionZ_shellZ join_pathrZ_execute_module) r tmprresultsZvalidation_resultZnew_module_argsrrr Zlog_path __class__r r rs*  zActionModule.run)NN)__name__ __module__ __qualname__rr __classcell__r r r!r r srN) Z __future__rrrrZ __metaclass__Zansible.errorsrZansible.plugins.actionrZansible.utils.varsrrr r r r s