|
|
|
@ -129,6 +129,7 @@ async def simulate_equipment(db_session: DbSession, assetnum: str):
|
|
|
|
yield f"data: {json.dumps({'status':'done','message':f'Simulation for {assetnum} completed successfully','data':combined})}\n\n"
|
|
|
|
yield f"data: {json.dumps({'status':'done','message':f'Simulation for {assetnum} completed successfully','data':combined})}\n\n"
|
|
|
|
|
|
|
|
|
|
|
|
headers = {
|
|
|
|
headers = {
|
|
|
|
|
|
|
|
"Content-type": "text/event-stream",
|
|
|
|
"Content-Type": "text/event-stream",
|
|
|
|
"Content-Type": "text/event-stream",
|
|
|
|
"Cache-Control": "no-cache, no-transform",
|
|
|
|
"Cache-Control": "no-cache, no-transform",
|
|
|
|
"Connection": "keep-alive",
|
|
|
|
"Connection": "keep-alive",
|
|
|
|
@ -179,6 +180,7 @@ async def simulate_all_equipment(db_session: DbSession):
|
|
|
|
yield f"data: {json.dumps({'status':'done', 'message':f'All simulations completed. Success: {success_count}, Errors: {error_count}'})}\\n\\n"
|
|
|
|
yield f"data: {json.dumps({'status':'done', 'message':f'All simulations completed. Success: {success_count}, Errors: {error_count}'})}\\n\\n"
|
|
|
|
|
|
|
|
|
|
|
|
headers = {
|
|
|
|
headers = {
|
|
|
|
|
|
|
|
"Content-type": "text/event-stream",
|
|
|
|
"Content-Type": "text/event-stream",
|
|
|
|
"Content-Type": "text/event-stream",
|
|
|
|
"Cache-Control": "no-cache, no-transform",
|
|
|
|
"Cache-Control": "no-cache, no-transform",
|
|
|
|
"Connection": "keep-alive",
|
|
|
|
"Connection": "keep-alive",
|
|
|
|
|