#NEWLINE# def test_dequeue_active_sorted_set( self ) : #NEWLINE# #INDENT# job_id = self . _get_job_id ( ) #NEWLINE# start_time = str ( generate_epoch ( ) ) #NEWLINE# response = self . queue . enqueue ( payload = self . _test_payload_1 , interval = 10000 , job_id = job_id , queue_id = self . _test_queue_id , queue_type = self . _test_queue_type ) #NEWLINE# response = self . queue . dequeue ( queue_type = self . _test_queue_type ) #NEWLINE# active_sorted_set_name = ( '%s:%s:active' % ( self . queue . _key_prefix , self . _test_queue_type ) ) #NEWLINE# end_time = str ( generate_epoch ( ) ) #NEWLINE# job_expire_timestamp = str ( ( int ( end_time ) + self . queue . _job_expire_interval ) ) #NEWLINE# job_id_list = self . queue . _r . zrangebyscore ( active_sorted_set_name , start_time , job_expire_timestamp ) #NEWLINE# self . assertEqual ( len ( end_time ) , 1 )