updated simple factory
This commit is contained in:
environments/factory
@ -12,6 +12,7 @@ class BaseFactory(object):
|
||||
self.level = h.one_hot_level(
|
||||
h.parse_level(Path(__file__).parent / self.LEVELS_DIR / f'{level}.txt')
|
||||
)#[np.newaxis, ...]
|
||||
self.slice_strings = {0: 'level', **{i: f'agent#{i}' for i in range(1, self.n_agents+1)}}
|
||||
self.reset()
|
||||
|
||||
def reset(self):
|
||||
@ -23,7 +24,6 @@ class BaseFactory(object):
|
||||
for i in range(self.n_agents):
|
||||
r, c = free_cells[i]
|
||||
self.agents[i, r, c] = 1
|
||||
free_cells = free_cells[self.n_agents:]
|
||||
self.state = np.concatenate((self.level[np.newaxis, ...], self.agents), 0)
|
||||
return self.state, 0, self.done, {}
|
||||
|
||||
@ -34,18 +34,21 @@ class BaseFactory(object):
|
||||
self.steps += 1
|
||||
r = 0
|
||||
# level, agent 1,..., agent n,
|
||||
collision_vecs = np.zeros((self.n_agents, self.state.shape[0])) # n_agents x n_slices
|
||||
for i, a in enumerate(actions):
|
||||
old_pos, new_pos, valid = h.check_agent_move(state=self.state, dim=i+1, action=a)
|
||||
if valid:
|
||||
self.make_move(i, old_pos, new_pos)
|
||||
collision_vecs = []
|
||||
else: # trying to leave the level
|
||||
collision_vecs[i, 0] = 1
|
||||
for i in range(self.n_agents): # might as well save the positions (redundant)
|
||||
agent_slice = self.state[i+1]
|
||||
x, y = np.argwhere(agent_slice == 1)[0]
|
||||
collisions_vec = self.state[:, x, y].copy() # otherwise you overwrite the grid/state
|
||||
collisions_vec[i+1] = 0 # no self-collisions
|
||||
collision_vecs.append(collisions_vec)
|
||||
reward, info = self.step_core(collisions_vec, actions, r)
|
||||
#collision_vecs.append(collisions_vec)
|
||||
collision_vecs[i] += collisions_vec
|
||||
reward, info = self.step_core(np.array(collision_vecs), actions, r)
|
||||
r += reward
|
||||
if self.steps >= self.max_steps:
|
||||
self.done = True
|
||||
@ -56,5 +59,11 @@ class BaseFactory(object):
|
||||
self.state[agent_i+1, x, y] = 0
|
||||
self.state[agent_i+1, x_new, y_new] = 1
|
||||
|
||||
def free_cells(self):
|
||||
free_cells = self.state.sum(0)
|
||||
free_cells = np.argwhere(free_cells == 0)
|
||||
np.random.shuffle(free_cells)
|
||||
return free_cells
|
||||
|
||||
def step_core(self, collisions_vec, actions, r):
|
||||
return 0, {}
|
||||
|
Reference in New Issue
Block a user