ansible.executor.process package

Submodules

ansible.executor.process.result module

class ansible.executor.process.result.ResultProcess(final_q, workers)

Bases: multiprocessing.process.Process

The result worker thread, which reads results from the results queue and fires off callbacks/etc. as necessary.

terminate()

run()

The main thread execution, which reads from the results queue indefinitely and sends callbacks/etc. when results are received.

ansible.executor.process.worker module

class ansible.executor.process.worker.WorkerProcess(rslt_q, task_vars, host, task, play_context, loader, variable_manager, shared_loader_obj)

Bases: multiprocessing.process.Process

The worker thread class, which uses TaskExecutor to run tasks read from a job queue and pushes results into a results queue for reading later.

run()

Called when the process is started. Pushes the result onto the results queue. We also remove the host from the blocked hosts list, to signify that they are ready for their next task.