Merge pull request #170 from PedroAVJ/add_auto_restart_for_celery

Add auto restart for celery

README.md

@@ -55,11 +55,6 @@ The chirps application makes use of Celery and RabbitMQ for job processing. Exec
 
 Both the rabbitmq and celery commands have `--stop` and `--restart` options as well.
 
-#### IMPORTANT CELERY TIP
-
-If you make changes to a Celery task, it must be restarted in order for those changes to be picked up. Simply run
-`./manage.py celery --restart`
-
 ### Run Webserver
 
 `./manage.py runserver`

chirps/base_app/management/commands/celery.py

@@ -2,6 +2,7 @@
 import os
 
 from django.core.management.base import BaseCommand
+from django.utils import autoreload
 
 
 class Command(BaseCommand):
@@ -18,12 +19,13 @@ def add_arguments(self, parser):
     def handle(self, *args, **options):
         """Handle the command."""
         if options['start']:
-            self.start()
+            self.stop()
+            autoreload.run_with_reloader(self.start)
         elif options['stop']:
             self.stop()
         elif options['restart']:
             self.stop()
-            self.start()
+            autoreload.run_with_reloader(self.start)
 
     def start(self):
         """Start the celery server."""