From cb459cd0a13453269215bcab118ffa00495df39c Mon Sep 17 00:00:00 2001 From: k4ml Date: Fri, 19 Feb 2016 17:01:42 +0900 Subject: [PATCH] Log id returned by broker This will make it easy to inspect broker directly for particular message. --- django_q/tasks.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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']