check celery on each request for result

This commit is contained in:
yangdsh 2020-02-17 21:05:31 +00:00 committed by Dana Van Aken
parent c8a537e9e0
commit 010a3ff267
1 changed files with 5 additions and 2 deletions

View File

@ -1194,8 +1194,11 @@ def give_result(request, upload_code): # pylint: disable=unused-argument
status_code = 200
else: # One or more tasks are still waiting to execute
response.update(celery_status='PENDING', message='Result not ready')
status_code = 202
celery_status = 'PENDING'
if CHECK_CELERY:
celery_status = utils.check_and_run_celery()
response.update(celery_status=celery_status, message='Result not ready')
status_code = 202
return HttpResponse(JSONUtil.dumps(response, pprint=True), status=status_code,
content_type='application/json')