diff --git a/django_q/tasks.py b/django_q/tasks.py index 4af1788..7d69388 100644 --- a/django_q/tasks.py +++ b/django_q/tasks.py @@ -48,7 +48,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']