Update neochessppo.py
Browse files- neochessppo.py +8 -46
neochessppo.py
CHANGED
|
@@ -1,19 +1,3 @@
|
|
| 1 |
-
# -*- coding: utf-8 -*-
|
| 2 |
-
"""NeoChessPPO.ipynb
|
| 3 |
-
|
| 4 |
-
Automatically generated by Colab.
|
| 5 |
-
|
| 6 |
-
Original file is located at
|
| 7 |
-
https://colab.research.google.com/drive/1wfdi_MmS5cEnvU_IIomlNObjzoGodqIC
|
| 8 |
-
"""
|
| 9 |
-
|
| 10 |
-
!git clone https://huggingface.co/sigmoidneuron123/NeoChess
|
| 11 |
-
|
| 12 |
-
!pip install torchrl
|
| 13 |
-
!pip install tensordict
|
| 14 |
-
!pip install gymnasium
|
| 15 |
-
!pip install chess
|
| 16 |
-
|
| 17 |
import torchrl
|
| 18 |
import torch
|
| 19 |
import chess
|
|
@@ -49,8 +33,6 @@ from torchrl.envs.libs.gym import set_gym_backend, GymWrapper
|
|
| 49 |
from torchrl.envs import GymEnv
|
| 50 |
from tensordict import TensorDict
|
| 51 |
|
| 52 |
-
!git clone https://huggingface.co/sigmoidneuron123/NeoChess
|
| 53 |
-
|
| 54 |
device = torch.device("cuda" if torch.cuda.is_available() else "cpu")
|
| 55 |
|
| 56 |
def board_to_tensor(board):
|
|
@@ -160,34 +142,13 @@ with set_gym_backend("gymnasium"):
|
|
| 160 |
include_fen=True,
|
| 161 |
include_san=False,
|
| 162 |
)
|
| 163 |
-
obs = env.reset()
|
| 164 |
-
|
| 165 |
-
!mv san_moves.txt /usr/local/lib/python3.11/dist-packages/torchrl/envs/custom/
|
| 166 |
-
|
| 167 |
-
!pip show torchrl gymnasium
|
| 168 |
-
|
| 169 |
-
obs = env.reset()
|
| 170 |
-
|
| 171 |
-
for _ in range(10):
|
| 172 |
-
legal_moves = obs["action_mask"].nonzero(as_tuple=False).squeeze(-1)
|
| 173 |
-
action = legal_moves[0] # example: pick first legal move
|
| 174 |
-
td_action = TensorDict({"action": action}, batch_size=obs.batch_size)
|
| 175 |
-
|
| 176 |
-
obs = env.step(td_action) # obs is the nested TensorDict
|
| 177 |
-
|
| 178 |
-
# Use the next observation for the next step:
|
| 179 |
-
obs = obs.get("next") # move to next state
|
| 180 |
-
|
| 181 |
-
board = chess.Board(obs["fen"])
|
| 182 |
-
print(board)
|
| 183 |
-
|
| 184 |
-
obs = env.reset()
|
| 185 |
-
obs
|
| 186 |
|
| 187 |
policy = Policy().to(device)
|
| 188 |
value = Value().to(device)
|
| 189 |
valweight = torch.load("NeoChess/chessy_model.pth",map_location=device)
|
| 190 |
value.load_state_dict(valweight)
|
|
|
|
|
|
|
| 191 |
|
| 192 |
def sample_masked_action(logits, mask):
|
| 193 |
masked_logits = logits.clone()
|
|
@@ -282,11 +243,10 @@ actor = ProbabilisticActor(
|
|
| 282 |
distribution_class=masked_categorical_factory,
|
| 283 |
return_log_prob=True,
|
| 284 |
)
|
| 285 |
-
|
| 286 |
-
|
| 287 |
obs = env.reset()
|
| 288 |
print(obs)
|
| 289 |
-
print(policy_module(obs)
|
| 290 |
print(value_module(obs))
|
| 291 |
print(actor(obs))
|
| 292 |
|
|
@@ -315,6 +275,7 @@ def train_ppo_chess(chess_env, num_iterations=1, frames_per_batch=100,
|
|
| 315 |
env = chess_env
|
| 316 |
# Create actor and value modules
|
| 317 |
actor_module = actor
|
|
|
|
| 318 |
|
| 319 |
collector = SyncDataCollector(
|
| 320 |
env,
|
|
@@ -451,6 +412,7 @@ def train_ppo_chess(chess_env, num_iterations=1, frames_per_batch=100,
|
|
| 451 |
replay_buffer.empty()
|
| 452 |
|
| 453 |
print("\nTraining completed!")
|
| 454 |
-
return actor_module, value_module, loss_module
|
| 455 |
|
| 456 |
-
train_ppo_chess(env)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
import torchrl
|
| 2 |
import torch
|
| 3 |
import chess
|
|
|
|
| 33 |
from torchrl.envs import GymEnv
|
| 34 |
from tensordict import TensorDict
|
| 35 |
|
|
|
|
|
|
|
| 36 |
device = torch.device("cuda" if torch.cuda.is_available() else "cpu")
|
| 37 |
|
| 38 |
def board_to_tensor(board):
|
|
|
|
| 142 |
include_fen=True,
|
| 143 |
include_san=False,
|
| 144 |
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 145 |
|
| 146 |
policy = Policy().to(device)
|
| 147 |
value = Value().to(device)
|
| 148 |
valweight = torch.load("NeoChess/chessy_model.pth",map_location=device)
|
| 149 |
value.load_state_dict(valweight)
|
| 150 |
+
polweight = torch.load("NeoChess/chessy_policy.pth")
|
| 151 |
+
policy.load_state_dict(polweight)
|
| 152 |
|
| 153 |
def sample_masked_action(logits, mask):
|
| 154 |
masked_logits = logits.clone()
|
|
|
|
| 243 |
distribution_class=masked_categorical_factory,
|
| 244 |
return_log_prob=True,
|
| 245 |
)
|
| 246 |
+
#test
|
|
|
|
| 247 |
obs = env.reset()
|
| 248 |
print(obs)
|
| 249 |
+
print(policy_module(obs))
|
| 250 |
print(value_module(obs))
|
| 251 |
print(actor(obs))
|
| 252 |
|
|
|
|
| 275 |
env = chess_env
|
| 276 |
# Create actor and value modules
|
| 277 |
actor_module = actor
|
| 278 |
+
global actor_module, value_module, loss_module
|
| 279 |
|
| 280 |
collector = SyncDataCollector(
|
| 281 |
env,
|
|
|
|
| 412 |
replay_buffer.empty()
|
| 413 |
|
| 414 |
print("\nTraining completed!")
|
|
|
|
| 415 |
|
| 416 |
+
train_ppo_chess(env)
|
| 417 |
+
torch.save(value.state_dict(),"chessy_model.pth")
|
| 418 |
+
torch.save(policy.state_dict(),"chessy_policy.pth")
|