Fabian
52 lines
1.6 KiB
Python
52 lines
1.6 KiB
Python
#!/usr/bin/env python3
|
|
"""Check ComfyUI API queue/history for errors."""
|
|
import paramiko, json
|
|
ssh = paramiko.SSHClient()
|
|
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
|
|
ssh.connect('192.168.178.150', username='fabian', key_filename=r'C:\Users\fabia\.ssh\id_ed25519')
|
|
|
|
def run(cmd, timeout=30):
|
|
_, stdout, stderr = ssh.exec_command(cmd, timeout=timeout)
|
|
return stdout.read().decode(), stderr.read().decode()
|
|
|
|
# Queue status
|
|
out, _ = run("curl -s http://localhost:8188/queue")
|
|
print("=== QUEUE ===")
|
|
try:
|
|
q = json.loads(out)
|
|
print(f"Running: {len(q.get('queue_running', []))}")
|
|
print(f"Pending: {len(q.get('queue_pending', []))}")
|
|
except:
|
|
print(out[:500])
|
|
|
|
# History
|
|
out, _ = run("curl -s http://localhost:8188/history")
|
|
print("\n=== HISTORY ===")
|
|
try:
|
|
h = json.loads(out)
|
|
for pid, info in h.items():
|
|
print(f"\nPrompt ID: {pid}")
|
|
status = info.get('status', {})
|
|
print(f" Status: {status}")
|
|
outputs = info.get('outputs', {})
|
|
for nid, nout in outputs.items():
|
|
print(f" Node {nid}: {list(nout.keys()) if isinstance(nout, dict) else nout}")
|
|
if not outputs:
|
|
print(" NO OUTPUTS")
|
|
except:
|
|
print(out[:2000])
|
|
|
|
# Check stderr output (nohup might redirect differently)
|
|
out, _ = run("cat /home/fabian/comfyui_err.log 2>/dev/null || echo 'no err log'")
|
|
print(f"\n=== STDERR LOG ===\n{out[:2000]}")
|
|
|
|
# Check full nohup output
|
|
out, _ = run("wc -l /home/fabian/comfyui.log 2>/dev/null")
|
|
print(f"\n=== LOG LINES: {out.strip()}")
|
|
|
|
# Check if there are processes actively computing
|
|
out, _ = run("bash -c 'top -bn1 | head -20'")
|
|
print(f"\n=== TOP ===\n{out}")
|
|
|
|
ssh.close()
|