Skip to content

Commit

Permalink
Merge pull request #1457 from FCP-INDI/tweak/overusage-report
Browse files Browse the repository at this point in the history
🔇 Comment out runtime_threads ⩼  threads
  • Loading branch information
sgiavasis authored Mar 10, 2021
2 parents 7c4b8b4 + 7f681fd commit 4c8193b
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions CPAC/utils/monitoring/draw_gantt_chart.py
Original file line number Diff line number Diff line change
Expand Up @@ -499,7 +499,7 @@ def resource_overusage_report(cblog):
> node.get('num_threads', 1) else None
] for node in [node for node in cb_dict_list if (
node.get('runtime_memory_gb', 0) > node.get('estimated_memory_gb', 1)
or node.get('runtime_threads', 0) - 1 > node.get('num_threads', 1)
# or node.get('runtime_threads', 0) - 1 > node.get('num_threads', 1)
)]}
text_report = ''
if excessive:
Expand All @@ -514,10 +514,12 @@ def resource_overusage_report(cblog):
' runtime > estimated\n' \
f' {excessive[node][0]} ' \
f'> {excessive[node][1]}\n'
if excessive[node][2]:
text_report += ' **threads**\n runtime > limit\n' \
f' {excessive[node][2]} ' \
f'> {excessive[node][3]}\n'
# JC: I'm not convinced 'runtime_threads' and 'threads' are
# comparable in nipype ~1.5.1
# if excessive[node][2]:
# text_report += ' **threads**\n runtime > limit\n' \
# f' {excessive[node][2]} ' \
# f'> {excessive[node][3]}\n'
text_report += dotted_line
return text_report, excessive

Expand Down

0 comments on commit 4c8193b

Please sign in to comment.