diff --git a/django_q/tasks.py b/django_q/tasks.py index 7da0a11..5f1c46b 100644 --- a/django_q/tasks.py +++ b/django_q/tasks.py @@ -51,7 +51,8 @@ def async(func, *args, **kwargs): if task.get('sync', False): return _sync(pack) # push it - broker.enqueue(pack) + enqueue_id = broker.enqueue(pack) + logger.info('Enqueued {}'.format(enqueue_id)) logger.debug('Pushed {}'.format(tag)) return task['id']