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

Paste accidents happen

Browse Source
This commit is contained in:
Ilan
2015-07-16 20:47:14 +02:00
parent af735c328e
commit af5e99249f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+1 -1
View File
@@ -359,7 +359,7 @@ def worker(task_queue, result_queue, timer, timeout=Conf.TIMEOUT):
# Get the function from the task # Get the function from the task
logger.info(_('{} processing [{}]').format(name, task['name'])) logger.info(_('{} processing [{}]').format(name, task['name']))
f = task['func'] f = task['func']
# if it's not an instance try to get it from the stringIncrement # if it's not an instance try to get it from the string
if not callable(task['func']): if not callable(task['func']):
try: try:
module, func = f.rsplit('.', 1) module, func = f.rsplit('.', 1)