File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -355,8 +355,9 @@ def _heartbeat(
355
355
356
356
if self ._resources_metrics_interval :
357
357
self ._add_metrics_to_dispatch (
358
- self ._get_sysinfo (interval = 1 ), join_on_fail = False
358
+ self ._get_sysinfo (interval = 1 ), join_on_fail = False , step = 0
359
359
)
360
+ res_step = 1
360
361
361
362
while not heartbeat_trigger .is_set ():
362
363
time .sleep (0.1 )
@@ -371,9 +372,10 @@ def _heartbeat(
371
372
# join would be called on this thread and a thread cannot
372
373
# join itself!
373
374
self ._add_metrics_to_dispatch (
374
- self ._get_sysinfo (), join_on_fail = False
375
+ self ._get_sysinfo (), join_on_fail = False , step = res_step
375
376
)
376
377
last_res_metric_call = res_time
378
+ res_step += 1
377
379
378
380
if time .time () - last_heartbeat < self ._heartbeat_interval :
379
381
continue
You can’t perform that action at this time.
0 commit comments