Commit f768c06d authored by Alan Taylor's avatar Alan Taylor

terminology change: processes -> threads

parent 315310e7
......@@ -207,11 +207,11 @@ def tidy_up_temporary_files(render_nodes):
# tidy up remote nodes
try:
num_processes = mp.cpu_count() * 5
num_threads = mp.cpu_count() * 5
except NotImplementedError:
num_processes = 5
num_threads = 5
with cf.ThreadPoolExecutor(max_workers=num_processes) as executor:
with cf.ThreadPoolExecutor(max_workers=num_threads) as executor:
delete_status = {executor.submit(_tidy_files, node): node for node in render_nodes}
for status in cf.as_completed(delete_status):
tidy_failed, node_ip = status.result()
......
......@@ -412,11 +412,11 @@ def remove_dead_nodes(available_nodes):
"""
# run tests and process results
try:
num_processes = mp.cpu_count() * 5
num_threads = mp.cpu_count() * 5
except NotImplementedError:
num_processes = 5
num_threads = 5
with cf.ThreadPoolExecutor(max_workers=num_processes) as executor:
with cf.ThreadPoolExecutor(max_workers=num_threads) as executor:
node_status = {executor.submit(_check_node, anode): anode for anode in available_nodes}
for status in cf.as_completed(node_status):
node, node_up, binloc = status.result()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment