mirror of
https://github.com/gryf/coach.git
synced 2025-12-18 19:50:17 +01:00
fixed bug in training worker
This commit is contained in:
@@ -18,9 +18,8 @@ def heatup(graph_manager):
|
|||||||
redis_ip=graph_manager.agent_params.memory.redis_ip,
|
redis_ip=graph_manager.agent_params.memory.redis_ip,
|
||||||
redis_port=graph_manager.agent_params.memory.redis_port)
|
redis_port=graph_manager.agent_params.memory.redis_port)
|
||||||
|
|
||||||
num_steps = graph_manager.schedule_params.heatup_steps.num_steps
|
while(memory.num_transitions() < graph_manager.heatup_steps.num_steps):
|
||||||
while(memory.num_transitions() < num_steps):
|
time.sleep(1)
|
||||||
time.sleep(10)
|
|
||||||
|
|
||||||
|
|
||||||
def training_worker(graph_manager, checkpoint_dir):
|
def training_worker(graph_manager, checkpoint_dir):
|
||||||
@@ -48,6 +47,7 @@ def training_worker(graph_manager, checkpoint_dir):
|
|||||||
|
|
||||||
graph_manager.save_checkpoint()
|
graph_manager.save_checkpoint()
|
||||||
|
|
||||||
|
# TODO: signal to workers that training is done
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
parser = argparse.ArgumentParser()
|
parser = argparse.ArgumentParser()
|
||||||
|
|||||||
Reference in New Issue
Block a user