18 lines
1.0 KiB
Python
18 lines
1.0 KiB
Python
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:])
|