(conn, stream_name)
Wait for the provided stream to become active.

    :type conn: boto.kinesis.layer1.KinesisConnection
    :param conn: A connection to Amazon Kinesis

    :type stream_name: str
    :param stream_name: The name of a stream.
Wait for the provided stream to become active.
Wait for the provided stream to become active .
def wait_for_stream(conn, stream_name):
    '''
    Wait for the provided stream to become active.

    :type conn: boto.kinesis.layer1.KinesisConnection
    :param conn: A connection to Amazon Kinesis

    :type stream_name: str
    :param stream_name: The name of a stream.
    '''
    SLEEP_TIME_SECONDS = 3
    status = get_stream_status(conn, stream_name)
    while status != 'ACTIVE':
        print('{stream_name} has status: {status}, sleeping for {secs} seconds'.format(
                stream_name = stream_name,
                status      = status,
                secs        = SLEEP_TIME_SECONDS))
        time.sleep(SLEEP_TIME_SECONDS) # sleep for 3 seconds
        status = get_stream_status(conn, stream_name)
def wait_for_stream ( conn , stream_name ) : SLEEP_TIME_SECONDS = 3 status = get_stream_status ( conn , stream_name ) while status != 'ACTIVE' : print ( '{stream_name} has status: {status}, sleeping for {secs} seconds' . format ( stream_name = stream_name , status = status , secs = SLEEP_TIME_SECONDS ) ) time . sleep ( SLEEP_TIME_SECONDS ) # sleep for 3 seconds status = get_stream_status ( conn , stream_name )