File tree Expand file tree Collapse file tree 2 files changed +7
-4
lines changed Expand file tree Collapse file tree 2 files changed +7
-4
lines changed Original file line number Diff line number Diff line change @@ -181,7 +181,10 @@ def run(self):
181
181
metrics_to_log [f"train/{ key } " ] = value .item ()
182
182
183
183
metrics_to_log ["train/lr" ] = lr * alpha
184
- if self .logger :
184
+
185
+ # Logging only on the first worker in the dashboard.
186
+ # Alternatively, you can use a distributed logger, or aggregate metrics from all workers.
187
+ if self .logger and self .name == "worker_0" :
185
188
for key , value in metrics_to_log .items ():
186
189
self .logger .log_scalar (key , value , collected_frames )
187
190
collector .shutdown ()
Original file line number Diff line number Diff line change 7
7
# collector
8
8
collector :
9
9
frames_per_batch : 800
10
- total_frames : 40_000_000
10
+ total_frames : 40_000_00
11
11
12
12
# logger
13
13
logger :
14
14
backend : wandb
15
- project_name : torchrl_example_a2c
15
+ project_name : torchrl_example_a3c
16
16
group_name : null
17
- exp_name : Atari_Schulman17
17
+ exp_name : a3c_atari_training
18
18
test_interval : 40_000_000
19
19
num_test_episodes : 3
20
20
video : False
You can’t perform that action at this time.
0 commit comments