mirrors/mindcraft
1
0
Fork 0
mirror of https://github.com/kolbytn/mindcraft.git synced 2025-09-10 12:02:59 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

one more try catch block around starting the server

Browse source
This commit is contained in:
Isadora White 2025-03-16 22:10:32 -07:00
parent 2e4974ddd8
commit fe4e75612d
1 changed files with 22 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
evaluation_script.py
View file

@ -11,6 +11,7 @@ import time
import filecmp import filecmp
import json import json
import glob import glob
import socket
from tqdm import tqdm from tqdm import tqdm
import boto3 import boto3
@ -322,7 +323,7 @@ def launch_server_experiment(task_path,
agent_profiles_str += f'\"{agent}\", ' agent_profiles_str += f'\"{agent}\", '
agent_profiles_str += f"\"{agent_profiles[-1]}\"]'" agent_profiles_str += f"\"{agent_profiles[-1]}\"]'"
print(agent_profiles_str) print(agent_profiles_str)
launch_world(server_path, session_name="server_" + session_name, agent_names=agent_names) launch_world(server_path, session_name="server_" + session_name, agent_names=agent_names, port=server_port)
subprocess.run(['tmux', 'new-session', '-d', '-s', session_name], check=True) subprocess.run(['tmux', 'new-session', '-d', '-s', session_name], check=True)
@ -542,16 +543,30 @@ def delete_server_files(dest_path):
delete_server_files(dest_path) delete_server_files(dest_path)
def launch_world(server_path="./server_data/", agent_names=["andy", "jill"], session_name="server"): def launch_world(server_path="./server_data/", agent_names=["andy", "jill"], session_name="server", port=55916):
"""Launch the Minecraft world.""" """Launch the Minecraft world."""
print(server_path) print(f"Launching Minecraft world with port {port}...")
cmd = f"cd {server_path} && java -jar server.jar" cmd = f"cd {server_path} && java -jar server.jar"
subprocess.run(['tmux', 'new-session', '-d', '-s', session_name], check=True) subprocess.run(['tmux', 'new-session', '-d', '-s', session_name], check=True)
subprocess.run(["tmux", "send-keys", "-t", session_name, cmd, "C-m"]) subprocess.run(["tmux", "send-keys", "-t", session_name, cmd, "C-m"])
# for agent in agent_names: time.sleep(10)
# print(f"\n\n/op {agent}\n\n") if not test_server_running(port):
# subprocess.run(["tmux", "send-keys", "-t", session_name, f"/op {agent}", "C-m"]) print("Server failed to start. Retrying...")
time.sleep(5) launch_world(server_path, agent_names, session_name, port)
def test_server_running(port=55916):
host = 'localhost'
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
try:
s.connect((host, port))
print("Server is running on port 55916")
return True
except ConnectionRefusedError:
print("Server is not running on port 55916")
return False
def kill_world(session_name="server"): def kill_world(session_name="server"):
"""Kill the Minecraft world.""" """Kill the Minecraft world."""