Log id returned by broker

This will make it easy to inspect broker directly for particular message.
This commit is contained in:
k4ml
2016-02-19 17:01:42 +09:00
parent 140891bedf
commit cb459cd0a1
+2 -1
View File
@@ -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']