#NEWLINE# def test_get_ready_streams_fire( self ) : #NEWLINE# #INDENT# current_time = datetime . datetime ( 2014 , 8 , 12 , 0 , 0 , 0 , 42 ) #NEWLINE# streams = self . db . get_ready_streams ( 10 , current_time ) #NEWLINE# self . assertEqual ( len ( streams ) , 3 ) #NEWLINE# stream_ids = [ stream . id for stream in streams ] #NEWLINE# self . assertIn ( 3 , stream_ids ) #NEWLINE# self . assertIn ( 4 , stream_ids ) #NEWLINE# self . assertIn ( 7 , stream_ids ) #NEWLINE# current_time = datetime . datetime ( 2014 , 8 , 10 , 12 , 0 , 0 , 42 ) #NEWLINE# streams = self . db . get_ready_streams ( 10 , current_time ) #NEWLINE# self . assertEqual ( len ( streams ) , 1 ) #NEWLINE# stream_ids = [ stream . id for stream in streams ] #NEWLINE# self . assertIn ( 3 , stream_ids ) #NEWLINE# current_time = datetime . datetime ( 2014 , 8 , 12 , 0 , 0 , 0 , 42 ) #NEWLINE# streams = self . db . get_ready_streams ( 1 , current_time ) #NEWLINE# self . assertEqual ( len ( streams ) , 1 )