mitogen/tests/ansible/integration/runner/forking_active.yml

- name: integration/runner/forking_active.yml
  hosts: test-targets
  tasks:
  - include_tasks: ../_mitogen_only.yml

  # Verify mitogen_task_isolation=fork triggers forking.

  - name: get regular process ID.
    custom_python_detect_environment:
    register: sync_proc1

  - name: get force-forked process ID.
    custom_python_detect_environment:
    register: fork_proc1
    vars:
      mitogen_task_isolation: fork

  - name: get force-forked process ID again.
    custom_python_detect_environment:
    register: fork_proc2
    vars:
      mitogen_task_isolation: fork

  - assert:
      that:
      - fork_proc1.pid != sync_proc1.pid
      - fork_proc1.pid != fork_proc2.pid
      fail_msg: |
        fork_proc1={{ fork_proc1 }}
        sync_proc1={{ sync_proc1 }}
        fork_proc2={{ fork_proc2 }}

  tags:
    - forking_active
    - mitogen_only
ansible: fork isolated tasks from correct parent. Closes #355. 6 years ago			`- name: integration/runner/forking_active.yml`
tests: use test-targets group, not all group 7 years ago			`hosts: test-targets`
ansible: enable forking when requested and for async jobs. Closes #105. References #155. mitogen/service.py: Refactor services to support individually exposed methods with different security policies for each method. - @mitogen.service.expose() to expose a method and set its policy - @mitogen.service.arg_spec() to validate input. - Require basic service message format to be a tuple of `(method, kwargs)`, where kwargs is always a dict. - Update DeduplicatingService to match the new scheme. ansible_mitogen/connection.py: - Rename 'method' to 'method_name' to disambiguate it from the service.call()'s method= argument. ansible_mitogen/planner.py: - Generate an ID for every job, sync or not, and fetch job results from JobResultService rather than via the initiating function call's return value. - Planner subclasses now get to select whether their Runner should run in a forked process. The base implementation requests this if the 'mitogen_isolation_mode=fork' task variable is present. ansible_mitogen/runner.py: Teach runners to deliver their result via JobResultService executing in their indirect parent mux process. ansible_mitogen/plugins/actions/mitogen_async_status.py: Split the implementation up into methods, and more compatibly emulate Ansible's existing output. ansible_mitogen/process.py: Mux processes now host JobResultService. ansible_mitogen/services.py: Update existing services to the new mitogen.service scheme, and implement JobResultService: * listen() method for synchronous jobs. planner.invoke() registers a Sender with the service prior to invoking the job, then sleeps waiting for the service to write the job result to the corresponding Receiver. * Non-blocking get() method for implementing mitogen_async_status action. * Child-accessible push() method for delivering task results. ansible_mitogen/target.py: New helpers for spawning a virginal subprocess on startup, from which asynchronous and mitogen_task_isolation=fork jobs are forked. Necessary to avoid a task inheriting potentially polluted/monkey-patched parent environment, since remaining jobs continue to run in the original child process. docs/ansible.rst: Add/merge/remove some behaviours/risks. tests/ansible/integration: New tests for forking/async. 7 years ago			`tasks:`
tests: Replace uses of ``include:``, unify skipping of mitogen only tests The tag mitogen_only is only informational for now. It may be possible to use it with ANSIBLE_SKIP_TAGS in the future. 8 months ago			`- include_tasks: ../_mitogen_only.yml`
ansible: enable forking when requested and for async jobs. Closes #105. References #155. mitogen/service.py: Refactor services to support individually exposed methods with different security policies for each method. - @mitogen.service.expose() to expose a method and set its policy - @mitogen.service.arg_spec() to validate input. - Require basic service message format to be a tuple of `(method, kwargs)`, where kwargs is always a dict. - Update DeduplicatingService to match the new scheme. ansible_mitogen/connection.py: - Rename 'method' to 'method_name' to disambiguate it from the service.call()'s method= argument. ansible_mitogen/planner.py: - Generate an ID for every job, sync or not, and fetch job results from JobResultService rather than via the initiating function call's return value. - Planner subclasses now get to select whether their Runner should run in a forked process. The base implementation requests this if the 'mitogen_isolation_mode=fork' task variable is present. ansible_mitogen/runner.py: Teach runners to deliver their result via JobResultService executing in their indirect parent mux process. ansible_mitogen/plugins/actions/mitogen_async_status.py: Split the implementation up into methods, and more compatibly emulate Ansible's existing output. ansible_mitogen/process.py: Mux processes now host JobResultService. ansible_mitogen/services.py: Update existing services to the new mitogen.service scheme, and implement JobResultService: * listen() method for synchronous jobs. planner.invoke() registers a Sender with the service prior to invoking the job, then sleeps waiting for the service to write the job result to the corresponding Receiver. * Non-blocking get() method for implementing mitogen_async_status action. * Child-accessible push() method for delivering task results. ansible_mitogen/target.py: New helpers for spawning a virginal subprocess on startup, from which asynchronous and mitogen_task_isolation=fork jobs are forked. Necessary to avoid a task inheriting potentially polluted/monkey-patched parent environment, since remaining jobs continue to run in the original child process. docs/ansible.rst: Add/merge/remove some behaviours/risks. tests/ansible/integration: New tests for forking/async. 7 years ago
			`# Verify mitogen_task_isolation=fork triggers forking.`

ansible: remove a bunch more aliasing from connection.py. 6 years ago			`- name: get regular process ID.`
			`custom_python_detect_environment:`
			`register: sync_proc1`

ansible: enable forking when requested and for async jobs. Closes #105. References #155. mitogen/service.py: Refactor services to support individually exposed methods with different security policies for each method. - @mitogen.service.expose() to expose a method and set its policy - @mitogen.service.arg_spec() to validate input. - Require basic service message format to be a tuple of `(method, kwargs)`, where kwargs is always a dict. - Update DeduplicatingService to match the new scheme. ansible_mitogen/connection.py: - Rename 'method' to 'method_name' to disambiguate it from the service.call()'s method= argument. ansible_mitogen/planner.py: - Generate an ID for every job, sync or not, and fetch job results from JobResultService rather than via the initiating function call's return value. - Planner subclasses now get to select whether their Runner should run in a forked process. The base implementation requests this if the 'mitogen_isolation_mode=fork' task variable is present. ansible_mitogen/runner.py: Teach runners to deliver their result via JobResultService executing in their indirect parent mux process. ansible_mitogen/plugins/actions/mitogen_async_status.py: Split the implementation up into methods, and more compatibly emulate Ansible's existing output. ansible_mitogen/process.py: Mux processes now host JobResultService. ansible_mitogen/services.py: Update existing services to the new mitogen.service scheme, and implement JobResultService: * listen() method for synchronous jobs. planner.invoke() registers a Sender with the service prior to invoking the job, then sleeps waiting for the service to write the job result to the corresponding Receiver. * Non-blocking get() method for implementing mitogen_async_status action. * Child-accessible push() method for delivering task results. ansible_mitogen/target.py: New helpers for spawning a virginal subprocess on startup, from which asynchronous and mitogen_task_isolation=fork jobs are forked. Necessary to avoid a task inheriting potentially polluted/monkey-patched parent environment, since remaining jobs continue to run in the original child process. docs/ansible.rst: Add/merge/remove some behaviours/risks. tests/ansible/integration: New tests for forking/async. 7 years ago			`- name: get force-forked process ID.`
			`custom_python_detect_environment:`
			`register: fork_proc1`
			`vars:`
			`mitogen_task_isolation: fork`

			`- name: get force-forked process ID again.`
			`custom_python_detect_environment:`
			`register: fork_proc2`
			`vars:`
			`mitogen_task_isolation: fork`

			`- assert:`
			`that:`
			`- fork_proc1.pid != sync_proc1.pid`
			`- fork_proc1.pid != fork_proc2.pid`
tests: Improve Ansible fail_msg formatting By switching to block style (`\|`) with clip (no `-` or `+`) the failure messages don't require quoting and gain a single trailing newline. This causes Ansible to print them as block style, when using the yaml stdout callback plugin. As a result the values have one less layer of quoting and quote escaping, making them much easier to read. 3 months ago			`fail_msg: \|`
			`fork_proc1={{ fork_proc1 }}`
			`sync_proc1={{ sync_proc1 }}`
			`fork_proc2={{ fork_proc2 }}`
ansible: fork isolated tasks from correct parent. Closes #355. 6 years ago
tests: Tag Ansible tests This makes it easier to run subsets using ANSIBLE_RUN_TAGS=... 3 years ago			`tags:`
			`- forking_active`
tests: Replace uses of ``include:``, unify skipping of mitogen only tests The tag mitogen_only is only informational for now. It may be possible to use it with ANSIBLE_SKIP_TAGS in the future. 8 months ago			`- mitogen_only`