python/ray/workflow/api.py
def sleep(duration: float) -> "DAGNode[Event]":
    """
    A workfow that resolves after sleeping for a given duration.
    """

    @ray.remote
    def end_time():
        return time.time() + duration

    return wait_for_event(TimerListener, end_time.bind())

    A workfow that resolves after sleeping for a given duration.
    
A workfow that resolves after sleeping for a given duration.
A workfow that resolves after sleeping for a given duration .
def sleep(duration: float) -> "DAGNode[Event]":
    @ray.remote
    def end_time():
        return time.time() + duration
    return wait_for_event(TimerListener, end_time.bind())
def sleep ( duration : float ) -> "DAGNode[Event]" : @ ray . remote def end_time ( ) : return time . time ( ) + duration return wait_for_event ( TimerListener , end_time . bind ( ) )
A workfow that resolves after sleeping for a given duration.
A workfow that resolves after sleeping for a given duration .
"""
    A workfow that resolves after sleeping for a given duration.
    """
duration
float