Function test_deploy_multi_app_basic

python/ray/serve/tests/test_cli.py:180–281

Deploys some valid config files and checks that the deployments work.

(serve_instance)

@pytest.mark.skipif(sys.platform == "win32", reason="File path incorrect on Windows.")
def test_deploy_multi_app_basic(serve_instance):
    """Deploys some valid config files and checks that the deployments work."""
    # Create absolute file names to YAML config files
    two_pizzas = os.path.join(
        os.path.dirname(__file__), "test_config_files", "two_pizzas.yaml"
    )
    pizza_world = os.path.join(
        os.path.dirname(__file__), "test_config_files", "pizza_world.yaml"
    )

    success_message_fragment = b"Sent deploy request successfully."

    # Ensure the CLI is idempotent
    num_iterations = 2
    for iteration in range(1, num_iterations + 1):
        print(f"*** Starting Iteration {iteration}/{num_iterations} ***\n")

        print("Deploying two pizzas config.")
        deploy_response = subprocess.check_output(["serve", "deploy", two_pizzas])
        assert success_message_fragment in deploy_response
        print("Deploy request sent successfully.")

        # Test add and mul for each of the two apps
        wait_for_condition(
            lambda: httpx.post(
                f"{get_application_url(app_name='app1')}", json=["ADD", 2]
            ).text
            == "3 pizzas please!",
            timeout=15,
        )
        wait_for_condition(
            lambda: httpx.post(
                f"{get_application_url(app_name='app1')}", json=["MUL", 2]
            ).text
            == "2 pizzas please!",
            timeout=15,
        )
        print('Application "app1" is reachable over HTTP.')
        wait_for_condition(
            lambda: httpx.post(
                f"{get_application_url(app_name='app2')}", json=["ADD", 2]
            ).text
            == "5 pizzas please!",
            timeout=15,
        )
        wait_for_condition(
            lambda: httpx.post(
                f"{get_application_url(app_name='app2')}", json=["MUL", 2]
            ).text
            == "4 pizzas please!",
            timeout=15,
        )
        print('Application "app2" is reachable over HTTP.')

        deployment_names = [
            DeploymentID(name="Router", app_name="app1"),
            DeploymentID(name="Multiplier", app_name="app1"),
            DeploymentID(name="Adder", app_name="app1"),