fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-09-22 14:38:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #136 from Koed00/dev

Browse Source 
Save task now creates or updates
This commit is contained in:
Ilan Steemers
2016-01-20 11:28:10 +01:00
parent e0f5b6f099 66771f274a
commit 5b3e69de58
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+13 -11
View File
@@ -408,17 +408,19 @@ def save_task(task, broker):
try:
if task['success'] and 0 < Conf.SAVE_LIMIT <= Success.objects.count():
Success.objects.last().delete()
Task.objects.create(id=task['id'],
name=task['name'],
func=task['func'],
hook=task.get('hook'),
args=task['args'],
kwargs=task['kwargs'],
started=task['started'],
stopped=task['stopped'],
result=task['result'],
group=task.get('group'),
success=task['success'])
Task.objects.update_or_create(id=task['id'],
name=task['name'],
defaults={
'func': task['func'],
'hook': task.get('hook'),
'args': task['args'],
'kwargs': task['kwargs'],
'started': task['started'],
'stopped': task['stopped'],
'result': task['result'],
'group': task.get('group'),
'success': task['success']}
)
except Exception as e:
logger.error(e)