Buckets:

Mercity
/

Desicion-Model-Custom

Files

xet

Mercity/Desicion-Model-Custom / code /ops /watch_routed_tail.py

Pranav2748

7 days ago

download

raw

703 Bytes

import time, os, re
p = "/workspace/decision-reasoner/logs/s1mb_routed.log"
pos, n = os.path.getsize(p) if os.path.exists(p) else 0, 0
while True:
    if os.path.exists(p):
        with open(p, errors="replace") as f:
            f.seek(pos); chunk = f.read(); pos = f.tell()
        for line in chunk.splitlines():
            if line.startswith("progress "):
                n += 1
                if n % 15 == 1: print(line[:400], flush=True)
            elif re.search(r'"routed"|think_stats|"name"|FAILED|Traceback|Error:|SCORED|ROUTED_DONE|OutOfMemory', line):
                print(line[:400], flush=True)
            if "ROUTED_DONE" in line:
                raise SystemExit
    time.sleep(20)

Xet Storage Details

Size:: 703 Bytes
Xet hash:: 1b37ff40352b230efe4f591c87d9bb45c549803fe095e40cf1b5276d8f74a78c

Xet efficiently stores files, intelligently splitting them into unique chunks and accelerating uploads and downloads. More info.

	import time, os, re
	p = "/workspace/decision-reasoner/logs/s1mb_routed.log"
	pos, n = os.path.getsize(p) if os.path.exists(p) else 0, 0
	while True:
	if os.path.exists(p):
	with open(p, errors="replace") as f:
	f.seek(pos); chunk = f.read(); pos = f.tell()
	for line in chunk.splitlines():
	if line.startswith("progress "):
	n += 1
	if n % 15 == 1: print(line[:400], flush=True)
	elif re.search(r'"routed"\|think_stats\|"name"\|FAILED\|Traceback\|Error:\|SCORED\|ROUTED_DONE\|OutOfMemory', line):
	print(line[:400], flush=True)
	if "ROUTED_DONE" in line:
	raise SystemExit
	time.sleep(20)