@@ -166,7 +166,7 @@ def _collect_range_runtime_stats(self, num_threads):
166
166
func_runtime_gb = float (func_node_stats ['runtime_memory_gb' ])
167
167
168
168
# Calc errors
169
- cmd_threads_err = cmd_threads_threads - num_threads
169
+ cmd_threads_err = cmd_runtime_threads - num_threads
170
170
cmd_gb_err = cmd_runtime_gb - num_gb
171
171
func_threads_err = func_runtime_threads - num_threads
172
172
func_gb_err = func_runtime_gb - num_gb
@@ -178,9 +178,9 @@ def _collect_range_runtime_stats(self, num_threads):
178
178
'cmd_runtime_gb' : cmd_runtime_gb ,
179
179
'func_runtime_threads' : func_runtime_threads ,
180
180
'func_runtime_gb' : func_runtime_gb ,
181
- 'cmd_thread_err ' : cmd_thread_err ,
181
+ 'cmd_threads_err ' : cmd_threads_err ,
182
182
'cmd_gb_err' : cmd_gb_err ,
183
- 'func_thread_err ' : func_thread_err ,
183
+ 'func_threads_err ' : func_threads_err ,
184
184
'func_gb_err' : func_gb_err }
185
185
# Append to list
186
186
dict_list .append (results_dict )
@@ -191,11 +191,11 @@ def _collect_range_runtime_stats(self, num_threads):
191
191
# Return dataframe
192
192
return runtime_results_df
193
193
194
- def tiest_collect_range (self ):
195
- num_threads = 1
196
- df = self ._collect_range_suntime_stats (num_threads )
194
+ def test_collect_range (self ):
195
+ num_threads = 8
196
+ df = self ._collect_range_runtime_stats (num_threads )
197
197
198
- df .to_csv ('/root/%d_thread_df.csv' )
198
+ df .to_csv ('/root/%d_thread_df.csv' % num_threads )
199
199
200
200
# Test node
201
201
def _run_cmdline_workflow (self , num_gb , num_threads ):
@@ -349,7 +349,7 @@ def _run_function_workflow(self, num_gb, num_threads):
349
349
350
350
# Test resources were used as expected in cmdline interface
351
351
@unittest .skipIf (run_profiler == False , skip_profile_msg )
352
- def test_cmdline_profiling (self ):
352
+ def tiest_cmdline_profiling (self ):
353
353
'''
354
354
Test runtime profiler correctly records workflow RAM/CPUs consumption
355
355
from a cmdline function
@@ -391,7 +391,7 @@ def test_cmdline_profiling(self):
391
391
392
392
# Test resources were used as expected
393
393
@unittest .skipIf (run_profiler == False , skip_profile_msg )
394
- def test_function_profiling (self ):
394
+ def tiest_function_profiling (self ):
395
395
'''
396
396
Test runtime profiler correctly records workflow RAM/CPUs consumption
397
397
from a python function
0 commit comments