Fix spelling of Length

Author: nchudleigh

celery_prometheus_exporter.py

@@ -209,7 +209,7 @@ def enable_events(self):
         self._app.control.enable_events()
 
 
-class QueueLenghtMonitoringThread(threading.Thread):
+class QueueLengthMonitoringThread(threading.Thread):
     periodicity_seconds = 30
 
     def __init__(self, app, queue_list):
@@ -221,7 +221,7 @@ def __init__(self, app, queue_list):
         if isinstance(self.connection, FallbackContext):
             self.connection = self.connection.fallback()
 
-        super(QueueLenghtMonitoringThread, self).__init__()
+        super(QueueLengthMonitoringThread, self).__init__()
 
     def measure_queues_length(self):
         for queue in self.queue_list:
@@ -361,7 +361,7 @@ def main():  # pragma: no cover
         else:
             queue_list = opts.queue_list
 
-        q = QueueLenghtMonitoringThread(app=app, queue_list=queue_list)
+        q = QueueLengthMonitoringThread(app=app, queue_list=queue_list)
 
         q.daemon = True
         q.start()

test/test_unit.py

@@ -18,7 +18,7 @@
     WorkerMonitoringThread, setup_metrics, MonitorThread, EnableEventsThread,
     TASKS,
     get_histogram_buckets_from_evn,
-    QueueLenghtMonitoringThread, QUEUE_LENGTH)
+    QueueLengthMonitoringThread, QUEUE_LENGTH)
 
 from celery_test_utils import get_celery_app, SampleTask
 
@@ -131,7 +131,7 @@ def test_can_measure_queue_length(self):
         celery_app = get_celery_app(queue='realqueue')
         sample_task = SampleTask()
         sample_task.app = celery_app
-        monitoring_thread_instance = QueueLenghtMonitoringThread(celery_app, queue_list=['realqueue'])
+        monitoring_thread_instance = QueueLengthMonitoringThread(celery_app, queue_list=['realqueue'])
 
         sample_task.delay()
         monitoring_thread_instance.measure_queues_length()
@@ -140,7 +140,7 @@ def test_can_measure_queue_length(self):
         self.assertEqual(1.0, sample)
 
     def test_set_zero_on_queue_length_when_an_channel_layer_error_occurs_during_queue_read(self):
-        instance = QueueLenghtMonitoringThread(app=self.app, queue_list=['noqueue'])
+        instance = QueueLengthMonitoringThread(app=self.app, queue_list=['noqueue'])
 
         instance.measure_queues_length()
         sample = REGISTRY.get_sample_value('celery_queue_length', {'queue_name':'noqueue'})