[#2977] Mark Celery features as deprecated.

ckan · Sep 12, 2016 · dd2edc3 · dd2edc3
1 parent 4f50fe3
commit dd2edc3
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/ckan/lib/celery_app.py b/ckan/lib/celery_app.py
@@ -1,5 +1,11 @@
 # encoding: utf-8
 
+'''
+Celery background tasks management.
+
+This module is DEPRECATED, use ``ckan.lib.jobs`` instead.
+'''
+
 import ConfigParser
 import os
 import logging
@@ -9,6 +15,8 @@
 
 log = logging.getLogger(__name__)
 
+log.warning('ckan.lib.celery_app is deprecated, use ckan.lib.jobs instead.')
+
 LIST_PARAMS = """CELERY_IMPORTS ADMINS ROUTES""".split()
 
 from celery import Celery

diff --git a/ckan/lib/cli.py b/ckan/lib/cli.py
@@ -946,6 +946,8 @@ def purge(self, dataset_ref):
 class Celery(CkanCommand):
     '''Celery daemon
 
+    This command is DEPRECATED, use `paster jobs` instead.
+
     Usage:
         celeryd <run>            - run the celery daemon
         celeryd run concurrency  - run the celery daemon with
@@ -973,6 +975,7 @@ def command(self):
                 error('Command %s not recognized' % cmd)
 
     def run_(self):
+        deprecation_warning(u'Use `paster jobs worker` instead.')
         default_ini = os.path.join(os.getcwd(), 'development.ini')
 
         if self.options.config:
@@ -989,6 +992,7 @@ def run_(self):
         celery.worker_main(argv=['celeryd', '--loglevel=INFO'] + celery_args)
 
     def view(self):
+        deprecation_warning(u'Use `paster jobs list` instead.')
         self._load_config()
         import ckan.model as model
         from kombu.transport.sqlalchemy.models import Message
@@ -1003,6 +1007,7 @@ def view(self):
                 print '%i: Invisible Sent:%s' % (message.id, message.sent_at)
 
     def clean(self):
+        deprecation_warning(u'Use `paster jobs clear` instead.')
         self._load_config()
         import ckan.model as model
         query = model.Session.execute("select * from kombu_message")

diff --git a/ckan/logic/action/get.py b/ckan/logic/action/get.py
@@ -1114,6 +1114,8 @@ def resource_view_list(context, data_dict):
 def resource_status_show(context, data_dict):
     '''Return the statuses of a resource's tasks.
 
+    This function is DEPRECATED.
+
     :param id: the id of the resource
     :type id: string