_ansible.py 文件源码

def __init__(self, hosts):
        self._task_ctx = None
        self._item_ctx = None
        # ansible doesn't have callback to tell us
        #   there is no host matched, so we do that 
        #   check by ourself using this list.
        self._hosts = copy.deepcopy(hosts)
        # ansible run jobs after `fork()` workers,
        #   shm will make those control vars synced.
        self._reaper_queue = multiprocessing.Queue()
        self._playbook_mode = multiprocessing.Value('I', 0)