import subprocess
code="""import asyncio,httpx,json,app
async def main():
 p=app.providers()['default'];jid='270cbfd0-dda1-438f-8b49-a85dcd5e3558'
 async with httpx.AsyncClient(timeout=20) as c:
  h=(await c.get(p.base_url+'/history/'+jid,headers=app.provider_headers(p))).json().get(jid,{})
  q=(await c.get(p.base_url+'/queue',headers=app.provider_headers(p))).json()
  print(json.dumps({'history':h.get('status'), 'output_nodes':list(h.get('outputs',{})), 'running':any(x[1]==jid for x in q.get('queue_running',[])), 'queued':any(x[1]==jid for x in q.get('queue_pending',[]))}))
asyncio.run(main())
"""
print(subprocess.check_output(['docker','exec','huobao-vdn-normalizer','python','-c',code],text=True))
r=subprocess.run(['docker','logs','--tail','35','comfyui'],capture_output=True,text=True)
text=r.stdout+r.stderr
lines=[l for l in text.replace('\r','\n').splitlines() if any(word in l for word in ['SelfLift','%|','Exception','Error','VDN','Prompt executed','OOM'])]
print('\n'.join(lines[-12:]))