fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-06 11:18:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

neater monitor text

Browse Source
This commit is contained in:
Ilan Steemers
2015-06-24 19:56:39 +02:00
parent 4556a8dc69
commit d0880d06ac
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/core.py
+1 -1
View File
@@ -248,7 +248,7 @@ def pusher(task_queue, e, list_key=Q_LIST):
def monitor(done_queue): def monitor(done_queue):
name = current_process().name name = current_process().name
logger.info("{} monitoring results at {}".format(name, current_process().pid)) logger.info("{} monitoring at {}".format(name, current_process().pid))
for task in iter(done_queue.get, 'STOP'): for task in iter(done_queue.get, 'STOP'):
if task['success']: if task['success']:
logger.info("Processed [{}]".format(task['name'])) logger.info("Processed [{}]".format(task['name']))