#NEWLINE# def test_dequeue_any_serial_lock_expired( self ) : #NEWLINE# #INDENT# 'Test that it raises a DequeueTimeout timeout' #NEWLINE# time . sleep ( 1 ) #NEWLINE# ( job , queue ) = Queue . dequeue_any ( [ self . sq ] , timeout = 1 ) #NEWLINE# self . assertEquals ( self . job . id , job . id )