python/ray/serve/pipeline/tests/test_generate.py
def _validate_consistent_python_output(
    deployment, dag, handle_by_name, input=None, output=None
):
    """Assert same input lead to same outputs across the following:
    1) Deployment handle returned from Deployment instance get_handle()
    2) Original executable Ray DAG
    3) Deployment handle return from serve public API get_deployment()
    """
    deployment_handle = deployment.get_handle()
    assert ray.get(deployment_handle.remote(input)) == output
    assert ray.get(dag.execute(input)) == output
    handle_by_name = serve.get_deployment(handle_by_name).get_handle()
    assert ray.get(handle_by_name.remote(input)) == output
Assert same input lead to same outputs across the following:
    1) Deployment handle returned from Deployment instance get_handle()
    2) Original executable Ray DAG
    3) Deployment handle return from serve public API get_deployment()
    
Assert same input lead to same outputs across the following:
1) Deployment handle returned from Deployment instance get_handle()
2) Original executable Ray DAG
3) Deployment handle return from serve public API get_deployment()
Assert same input lead to same outputs across the following : 1 ) Deployment handle returned from Deployment instance get_handle () 2 ) Original executable Ray DAG 3 ) Deployment handle return from serve public API get_deployment ()
def _validate_consistent_python_output(
    deployment, dag, handle_by_name, input=None, output=None
):
    deployment_handle = deployment.get_handle()
    assert ray.get(deployment_handle.remote(input)) == output
    assert ray.get(dag.execute(input)) == output
    handle_by_name = serve.get_deployment(handle_by_name).get_handle()
    assert ray.get(handle_by_name.remote(input)) == output
def _validate_consistent_python_output ( deployment , dag , handle_by_name , input = None , output = None ) : deployment_handle = deployment . get_handle ( ) assert ray . get ( deployment_handle . remote ( input ) ) == output assert ray . get ( dag . execute ( input ) ) == output handle_by_name = serve . get_deployment ( handle_by_name ) . get_handle ( ) assert ray . get ( handle_by_name . remote ( input ) ) == output
Assert same input lead to same outputs across the following:
1) Deployment handle returned from Deployment instance get_handle()
2) Original executable Ray DAG
3) Deployment handle return from serve public API get_deployment()
Assert same input lead to same outputs across the following : 1 ) Deployment handle returned from Deployment instance get_handle () 2 ) Original executable Ray DAG 3 ) Deployment handle return from serve public API get_deployment ()
"""Assert same input lead to same outputs across the following:
    1) Deployment handle returned from Deployment instance get_handle()
    2) Original executable Ray DAG
    3) Deployment handle return from serve public API get_deployment()
    """
deployment
dag
handle_by_name
input
output