Private
Public Access
1
0
This commit is contained in:
Sander Roosendaal
2017-10-30 17:33:58 +01:00
parent 537b7392e6
commit 5fe6db02dc

View File

@@ -250,13 +250,13 @@ def kill_async_job(request,id='aap'):
if settings.DEBUG: if settings.DEBUG:
job = celery_result.AsyncResult(id) job = celery_result.AsyncResult(id)
job.revoke() job.revoke()
remove_asynctask(request,id)
else: else:
try: try:
cancel_job(id) cancel_job(id,connect=redis_connection)
except NoSuchJobError: except NoSuchJobError:
pass pass
remove_asynctask(request,id)
url = reverse(session_jobs_status) url = reverse(session_jobs_status)
return HttpResponseRedirect(url) return HttpResponseRedirect(url)