Skip to content

Commit 2cbb9c9

Browse files
committed
Merge branch 'devel'
2 parents ccfb9fd + 896e99f commit 2cbb9c9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

corrections/taskmanager.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -249,12 +249,12 @@ def save_results(self, result):
249249

250250
# Calculate mean elapsed time using "streaming weighted mean" with (alpha=0.1):
251251
# https://dev.to/nestedsoftware/exponential-moving-average-on-streaming-data-4hhl
252-
if self.summary['mean_elaptime'] is None:
252+
if self.summary['mean_elaptime'] is None and result.get('elaptime_corr') is not None:
253253
self.summary['mean_elaptime'] = result['elaptime_corr']
254254
elif result.get('elaptime_corr') is not None:
255255
self.summary['mean_elaptime'] += 0.1 * (result['elaptime_corr'] - self.summary['mean_elaptime'])
256256

257-
if self.summary['mean_worker_waittime'] is None:
257+
if self.summary['mean_worker_waittime'] is None and result.get('worker_wait_time') is not None:
258258
self.summary['mean_worker_waittime'] = result['worker_wait_time']
259259
elif result.get('worker_wait_time') is not None:
260260
self.summary['mean_worker_waittime'] += 0.1 * (result['worker_wait_time'] - self.summary['mean_worker_waittime'])

0 commit comments

Comments
 (0)