����JFIF���������
__ __ __ __ _____ _ _ _____ _ _ _ | \/ | \ \ / / | __ \ (_) | | / ____| | | | | | \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | | | |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | | | | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | | |_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1 if you need WebShell for Seo everyday contact me on Telegram Telegram Address : @jackleetFor_More_Tools:
# -*- coding: utf-8 -*-
# Copyright: (c) 2012, Michael DeHaan <michael.dehaan@gmail.com>, and others
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
from __future__ import absolute_import, division, print_function
__metaclass__ = type
DOCUMENTATION = r'''
---
module: async_status
short_description: Obtain status of asynchronous task
description:
- This module gets the status of an asynchronous task.
- This module is also supported for Windows targets.
version_added: "0.5"
options:
jid:
description:
- Job or task identifier
type: str
required: true
mode:
description:
- If C(status), obtain the status.
- If C(cleanup), clean up the async job cache (by default in C(~/.ansible_async/)) for the specified job I(jid).
type: str
choices: [ cleanup, status ]
default: status
extends_documentation_fragment:
- action_common_attributes
- action_common_attributes.flow
attributes:
action:
support: full
async:
support: none
check_mode:
support: none
diff_mode:
support: none
bypass_host_loop:
support: none
platform:
support: full
platforms: posix, windows
seealso:
- ref: playbooks_async
description: Detailed information on how to use asynchronous actions and polling.
author:
- Ansible Core Team
- Michael DeHaan
'''
EXAMPLES = r'''
---
- name: Asynchronous yum task
ansible.builtin.yum:
name: docker-io
state: present
async: 1000
poll: 0
register: yum_sleeper
- name: Wait for asynchronous job to end
ansible.builtin.async_status:
jid: '{{ yum_sleeper.ansible_job_id }}'
register: job_result
until: job_result.finished
retries: 100
delay: 10
'''
RETURN = r'''
ansible_job_id:
description: The asynchronous job id
returned: success
type: str
sample: '360874038559.4169'
finished:
description: Whether the asynchronous job has finished (C(1)) or not (C(0))
returned: always
type: int
sample: 1
started:
description: Whether the asynchronous job has started (C(1)) or not (C(0))
returned: always
type: int
sample: 1
stdout:
description: Any output returned by async_wrapper
returned: always
type: str
stderr:
description: Any errors returned by async_wrapper
returned: always
type: str
erased:
description: Path to erased job file
returned: when file is erased
type: str
'''
import json
import os
from ansible.module_utils.basic import AnsibleModule
from ansible.module_utils.six import iteritems
from ansible.module_utils._text import to_native
def main():
module = AnsibleModule(argument_spec=dict(
jid=dict(type='str', required=True),
mode=dict(type='str', default='status', choices=['cleanup', 'status']),
# passed in from the async_status action plugin
_async_dir=dict(type='path', required=True),
))
mode = module.params['mode']
jid = module.params['jid']
async_dir = module.params['_async_dir']
# setup logging directory
logdir = os.path.expanduser(async_dir)
log_path = os.path.join(logdir, jid)
if not os.path.exists(log_path):
module.fail_json(msg="could not find job", ansible_job_id=jid, started=1, finished=1)
if mode == 'cleanup':
os.unlink(log_path)
module.exit_json(ansible_job_id=jid, erased=log_path)
# NOT in cleanup mode, assume regular status mode
# no remote kill mode currently exists, but probably should
# consider log_path + ".pid" file and also unlink that above
data = None
try:
with open(log_path) as f:
data = json.loads(f.read())
except Exception:
if not data:
# file not written yet? That means it is running
module.exit_json(results_file=log_path, ansible_job_id=jid, started=1, finished=0)
else:
module.fail_json(ansible_job_id=jid, results_file=log_path,
msg="Could not parse job output: %s" % data, started=1, finished=1)
if 'started' not in data:
data['finished'] = 1
data['ansible_job_id'] = jid
elif 'finished' not in data:
data['finished'] = 0
# Fix error: TypeError: exit_json() keywords must be strings
data = {to_native(k): v for k, v in iteritems(data)}
module.exit_json(**data)
if __name__ == '__main__':
main()
| Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| __pycache__ | Folder | 0755 |
|
|
| __init__.py | File | 0 B | 0644 |
|
| _include.py | File | 3.06 KB | 0644 |
|
| add_host.py | File | 3.82 KB | 0644 |
|
| apt.py | File | 57.4 KB | 0644 |
|
| apt_key.py | File | 17.45 KB | 0644 |
|
| apt_repository.py | File | 28.39 KB | 0644 |
|
| assemble.py | File | 8.76 KB | 0644 |
|
| assert.py | File | 2.75 KB | 0644 |
|
| async_status.py | File | 4.29 KB | 0644 |
|
| async_wrapper.py | File | 11.43 KB | 0644 |
|
| blockinfile.py | File | 13.29 KB | 0644 |
|
| command.py | File | 12.64 KB | 0644 |
|
| copy.py | File | 34.75 KB | 0644 |
|
| cron.py | File | 25.57 KB | 0644 |
|
| debconf.py | File | 7.55 KB | 0644 |
|
| debug.py | File | 2.89 KB | 0644 |
|
| dnf.py | File | 58.16 KB | 0644 |
|
| dpkg_selections.py | File | 2.35 KB | 0644 |
|
| expect.py | File | 8.33 KB | 0644 |
|
| fail.py | File | 1.67 KB | 0644 |
|
| fetch.py | File | 4.17 KB | 0644 |
|
| file.py | File | 39.93 KB | 0644 |
|
| find.py | File | 18.73 KB | 0644 |
|
| gather_facts.py | File | 2.5 KB | 0644 |
|
| get_url.py | File | 26.22 KB | 0644 |
|
| getent.py | File | 5.56 KB | 0644 |
|
| git.py | File | 55.22 KB | 0644 |
|
| group.py | File | 19.57 KB | 0644 |
|
| group_by.py | File | 2.41 KB | 0644 |
|
| hostname.py | File | 28.12 KB | 0644 |
|
| import_playbook.py | File | 2.06 KB | 0644 |
|
| import_role.py | File | 3.27 KB | 0644 |
|
| import_tasks.py | File | 2.14 KB | 0644 |
|
| include_role.py | File | 4.15 KB | 0644 |
|
| include_tasks.py | File | 2.64 KB | 0644 |
|
| include_vars.py | File | 6.45 KB | 0644 |
|
| iptables.py | File | 32.27 KB | 0644 |
|
| known_hosts.py | File | 13.5 KB | 0644 |
|
| lineinfile.py | File | 23.39 KB | 0644 |
|
| meta.py | File | 5.84 KB | 0644 |
|
| package.py | File | 3.33 KB | 0644 |
|
| package_facts.py | File | 17.71 KB | 0644 |
|
| pause.py | File | 3.44 KB | 0644 |
|
| ping.py | File | 2.32 KB | 0644 |
|
| pip.py | File | 30 KB | 0644 |
|
| raw.py | File | 3.57 KB | 0644 |
|
| reboot.py | File | 4.64 KB | 0644 |
|
| replace.py | File | 11.19 KB | 0644 |
|
| rpm_key.py | File | 8.48 KB | 0644 |
|
| script.py | File | 4.03 KB | 0644 |
|
| service.py | File | 63.85 KB | 0644 |
|
| service_facts.py | File | 16.73 KB | 0644 |
|
| set_fact.py | File | 5.62 KB | 0644 |
|
| set_stats.py | File | 2.6 KB | 0644 |
|
| setup.py | File | 10.79 KB | 0644 |
|
| shell.py | File | 6.57 KB | 0644 |
|
| slurp.py | File | 3.19 KB | 0644 |
|
| stat.py | File | 19.62 KB | 0644 |
|
| subversion.py | File | 13.22 KB | 0644 |
|
| systemd.py | File | 22.82 KB | 0644 |
|
| systemd_service.py | File | 22.82 KB | 0644 |
|
| sysvinit.py | File | 13.47 KB | 0644 |
|
| tempfile.py | File | 3.42 KB | 0644 |
|
| template.py | File | 3.1 KB | 0644 |
|
| unarchive.py | File | 42.79 KB | 0644 |
|
| uri.py | File | 27.78 KB | 0644 |
|
| user.py | File | 114.18 KB | 0644 |
|
| validate_argument_spec.py | File | 2.99 KB | 0644 |
|
| wait_for.py | File | 25.91 KB | 0644 |
|
| wait_for_connection.py | File | 3.38 KB | 0644 |
|
| yum.py | File | 72.05 KB | 0644 |
|
| yum_repository.py | File | 24.82 KB | 0644 |
|