tests/pytests/integration/ssh/state/test_parallel.py - master - githubmirror/salt

tests/pytests/integration/ssh/state/test_parallel.py

67 строк2 KB

Daniel A. Wozniak

Improve salt-ssh relenv/thin parity and fix various regressions

05 апр 2026, 01:26

05 апр 2026, 01:26a164b4e

"""
Verify salt-ssh states support ``parallel``.
"""

import pytest

from tests.support.helpers import system_python_version

pytestmark = [
    pytest.mark.skip_on_windows(reason="salt-ssh not available on Windows"),
    pytest.mark.slow_test,
    pytest.mark.skipif(
        system_python_version() < (3, 10),
        reason="System python too old for these tests",
    ),
]


@pytest.fixture(scope="module", autouse=True)
def state_tree_parallel(base_env_state_tree_root_dir):
    top_file = """
    base:
      'localhost':
        - parallel
      '127.0.0.1':
        - parallel
    """
    state_file = """
    {%- for i in range(5) %}
    This runs in parallel {{ i }}:
      cmd.run:
        - name: sleep 0.{{ i }}
        - parallel: true
    {%- endfor %}
    """
    top_tempfile = pytest.helpers.temp_file(
        "top.sls", top_file, base_env_state_tree_root_dir
    )
    state_tempfile = pytest.helpers.temp_file(
        "parallel.sls", state_file, base_env_state_tree_root_dir
    )
    with top_tempfile, state_tempfile:
        yield


@pytest.mark.parametrize(
    "args",
    (
        pytest.param(("state.sls", "parallel"), id="sls"),
        pytest.param(("state.highstate",), id="highstate"),
        pytest.param(("state.top", "top.sls"), id="top"),
    ),
)
def test_it(salt_ssh_cli_parameterized, args):
    """
    Ensure states with ``parallel: true`` do not cause a crash.
    This does not check that they were actually run in parallel
    since that would result either in a long-running or flaky test.
    """
    ret = salt_ssh_cli_parameterized.run(*args)
    assert ret.returncode == 0
    assert isinstance(ret.data, dict)
    for i in range(5):
        key = f"cmd_|-This runs in parallel {i}_|-sleep 0.{i}_|-run"
        assert key in ret.data
        assert "pid" in ret.data[key]["changes"]
        assert ret.data[key]["changes"]["retcode"] == 0