Buckets:

Mercity
/

Desicion-Model-Custom

Files

xet

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

Pranav2748

7 days ago

download

raw

658 Bytes

import time, os, re
p = "/workspace/decision-reasoner/logs/s1mb_routed.log"
pos, n = 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:: 658 Bytes
Xet hash:: 9e36c82a155beb9b32c5b6a5890e890be6dc45bf9fc1370cecb32945ec4e118e

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 = 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)