#NEWLINE# def test_dequeue_metrics_per_queue_dequeue_counter( 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 = response . _test_queue_id , queue_type = self . _test_queue_type ) #NEWLINE# response = self . queue . dequeue ( queue_type = self . _test_queue_type ) #NEWLINE# timestamp = int ( generate_epoch ( ) ) #NEWLINE# timestamp_minute = str ( int ( ( math . floor ( ( timestamp / 60000.0 ) ) * 60000 ) ) ) #NEWLINE# counter_value = self . queue . _r . get ( ( '%s:%s:%s:dequeue_counter:%s' % ( self . queue . _key_prefix , self . _test_queue_type , self . _test_queue_id , timestamp_minute ) ) ) #NEWLINE# self . assertEqual ( counter_value , '1' )