#NEWLINE# def test_requeue_requeue_limit_neg_1( self ) : #NEWLINE# #INDENT# job_id = self . _get_job_id ( ) #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 , requeue_limit = self . _test_requeue_limit_neg_1 ) #NEWLINE# response = self . queue . dequeue ( queue_type = self . _test_queue_type ) #NEWLINE# self . assertEqual ( response [ 'requeues_remaining' ] , self . _test_requeue_limit_neg_1 ) #NEWLINE# time . sleep ( ( self . queue . _job_expire_interval / 1000.0 ) ) #NEWLINE# self . queue . requeue ( ) #NEWLINE# response = self . queue . dequeue ( queue_type = self . _test_queue_type ) #NEWLINE# self . assertEqual ( response [ 'requeues_remaining' ] , self . _test_requeue_limit_neg_1 ) #NEWLINE# time . sleep ( ( self . queue . _job_expire_interval / 1000.0 ) ) #NEWLINE# self . queue . requeue ( ) #NEWLINE# response = self . queue . dequeue ( queue_type = self . _test_queue_type ) #NEWLINE# self . assertEqual ( response [ 'requeues_remaining' ] , self . _test_requeue_limit_neg_1 ) #NEWLINE# time . sleep ( ( self . queue . _job_expire_interval / 1000.0 ) ) #NEWLINE# self . queue . requeue ( ) #NEWLINE# response = self . queue . dequeue ( queue_type = self . _test_queue_type ) #NEWLINE# self . assertEqual ( response [ 'requeues_remaining' ] , self . _test_requeue_limit_neg_1 ) #NEWLINE# time . sleep ( ( self . queue . _job_expire_interval / 1000.0 ) ) #NEWLINE# self . queue . requeue ( ) #NEWLINE# self . assertEqual ( response [ 'requeues_remaining' ] , self . _test_requeue_limit_neg_1 ) #NEWLINE# time . sleep ( ( self . queue . _job_expire_interval / 1000.0 ) )