python/ray/workflow/api.py
def continuation(dag_node: "DAGNode") -> Union[Workflow, ray.ObjectRef]:
    """Converts a DAG into a continuation.

    The result depends on the context. If it is inside a workflow, it
    returns a workflow; otherwise it executes and get the result of
    the DAG.

    Args:
        dag_node: The DAG to be converted.
    """
    from ray.workflow.workflow_context import in_workflow_execution

    if not isinstance(dag_node, DAGNode):
        raise TypeError("Input should be a DAG.")

    if in_workflow_execution():
        return create(dag_node)
    return ray.get(dag_node.execute())
Converts a DAG into a continuation.

    The result depends on the context. If it is inside a workflow, it
    returns a workflow; otherwise it executes and get the result of
    the DAG.

    Args:
        dag_node: The DAG to be converted.
    
Converts a DAG into a continuation.
The result depends on the context. If it is inside a workflow, it
returns a workflow; otherwise it executes and get the result of
the DAG.
Converts a DAG into a continuation . The result depends on the context . If it is inside a workflow it returns a workflow ; otherwise it executes and get the result of the DAG .
def continuation(dag_node: "DAGNode") -> Union[Workflow, ray.ObjectRef]:
    from ray.workflow.workflow_context import in_workflow_execution
    if not isinstance(dag_node, DAGNode):
        raise TypeError("Input should be a DAG.")
    if in_workflow_execution():
        return create(dag_node)
    return ray.get(dag_node.execute())
def continuation ( dag_node : "DAGNode" ) -> Union [ Workflow , ray . ObjectRef ] : from ray . workflow . workflow_context import in_workflow_execution if not isinstance ( dag_node , DAGNode ) : raise TypeError ( "Input should be a DAG." ) if in_workflow_execution ( ) : return create ( dag_node ) return ray . get ( dag_node . execute ( ) )
Converts a DAG into a continuation.
Converts a DAG into a continuation .
"""Converts a DAG into a continuation.

    The result depends on the context. If it is inside a workflow, it
    returns a workflow; otherwise it executes and get the result of
    the DAG.

    Args:
        dag_node: The DAG to be converted.
    """
dag_node
"DAGNode"
The DAG to be converted.
The DAG to be converted .