import subprocess
code="""import asyncio,httpx,json,app
async def main():
 p=app.providers()['default']
 async with httpx.AsyncClient(timeout=20) as c:
  d=(await c.get(p.base_url+'/object_info',headers=app.provider_headers(p))).json()
  print('save_format',json.dumps(d['SaveImageAdvanced']['input']))
  r=await c.get(p.base_url+'/history/b20376e4-1cb3-4d70-95f5-e07f8794e3df',headers=app.provider_headers(p))
  j=r.json().get('b20376e4-1cb3-4d70-95f5-e07f8794e3df',{})
  print('VDN history',json.dumps({'status':j.get('status'),'outputs':list(j.get('outputs',{}))}))
  q=(await c.get(p.base_url+'/queue',headers=app.provider_headers(p))).json()
  print('queues',json.dumps({k:[{'id':i[1],'nodes':len(i[2])} for i in q.get(k,[])] for k in ['queue_running','queue_pending']}))
asyncio.run(main())
"""
print(subprocess.check_output(['docker','exec','huobao-vdn-normalizer','python','-c',code],text=True))
logs=subprocess.run(['docker','logs','--tail','12','comfyui'],text=True,capture_output=True)
print((logs.stdout+logs.stderr)[-3000:])