def handle(self, *args, **kwargs):
    print('Starting celery worker with autoreload')
    run_with_reloader(restart_celery)
def handle(self, *args, **kwargs):
    print('Starting celery worker with autoreload')
    run_with_reloader(restart_celery)