Merge pull request #1529 from rtfd/remove-celery-debugging

Remove celery debugging/montioring views

Author: ericholscher

readthedocs/core/management/commands/pull.py

@@ -6,7 +6,6 @@
 from readthedocs.builds.constants import LATEST
 from readthedocs.projects import tasks, utils
 
-import redis
 
 log = logging.getLogger(__name__)
 

readthedocs/core/views.py

@@ -16,7 +16,6 @@
 
 from haystack.query import EmptySearchQuerySet
 from haystack.query import SearchQuerySet
-from celery.task.control import inspect  # noqa: pylint false positive
 import stripe
 
 from readthedocs.builds.models import Build
@@ -35,7 +34,6 @@
 import mimetypes
 import os
 import logging
-import redis
 import re
 
 log = logging.getLogger(__name__)
@@ -77,42 +75,6 @@ def random_page(request, project_slug=None):
     return HttpResponseRedirect(url)
 
 
-def queue_depth(request):
-    r = redis.Redis(**settings.REDIS)
-    return HttpResponse(r.llen('celery'))
-
-
-def queue_info(request):
-    i = inspect()
-    active_pks = []
-    reserved_pks = []
-    resp = ""
-
-    active = i.active()
-    if active:
-        try:
-            for obj in active['build']:
-                kwargs = eval(obj['kwargs'])
-                active_pks.append(str(kwargs['pk']))
-            active_resp = "Active: %s  " % " ".join(active_pks)
-            resp += active_resp
-        except Exception, e:
-            resp += str(e)
-
-    reserved = i.reserved()
-    if reserved:
-        try:
-            for obj in reserved['build']:
-                kwrags = eval(obj['kwargs'])
-                reserved_pks.append(str(kwargs['pk']))
-            reserved_resp = " | Reserved: %s" % " ".join(reserved_pks)
-            resp += reserved_resp
-        except Exception, e:
-            resp += str(e)
-
-    return HttpResponse(resp)
-
-
 def live_builds(request):
     builds = Build.objects.filter(state='building')[:5]
     websocket_host = getattr(settings, 'WEBSOCKET_HOST', 'localhost:8088')

readthedocs/urls.py

@@ -111,8 +111,6 @@
         name='random_page'),
     url(r'^random/$', 'readthedocs.core.views.random_page', name='random_page'),
     url(r'^sustainability/', include('readthedocs.donate.urls')),
-    url(r'^depth/$', 'readthedocs.core.views.queue_depth', name='queue_depth'),
-    url(r'^queue_info/$', 'readthedocs.core.views.queue_info', name='queue_info'),
     url(r'^live/$', 'readthedocs.core.views.live_builds', name='live_builds'),
     url(r'^500/$', 'readthedocs.core.views.divide_by_zero', name='divide_by_zero'),
     url(r'^filter/version/$',