class task_check(AuthententicatedOrReadOnlyAPIView): content_negotiation_class = IgnoreClientContentNegotiation def get(self, request): timeout = int(request.query_params.get(‘timeout’, 300)) task_id = request.session.get(‘pending_task_id’) if not task_id: return HttpResponse(“No pending task”, status=404) def event_stream(): start_time = time.time() while True: if time.time() – start_time > timeout: del request.session[‘pending_task_id’] request.session.modified = True yield f”data: {json.dumps({‘status’: ‘TIMEOUT’})}nn” break event_task_id = request.session.get(‘pending_task_id’) if not event_task_id: yield f”data: {json.dumps({‘status’: […]