fix: simplify parallel container stop

This commit is contained in:
Roman 2025-03-05 06:55:21 +00:00
parent d9e207fb1d
commit 45401bf437
No known key found for this signature in database
GPG Key ID: BB3828275C58EFF1

View File

@ -86,7 +86,7 @@ def close_open_nodes(attach_logs_on_fail):
logger.debug(f"Running fixture teardown: {inspect.currentframe().f_code.co_name}")
crashed_containers = []
with ThreadPoolExecutor(max_workers=30) as executor:
node_cleanups = [executor.submit(stop_node, node) for node in DS.nomos_nodes] + [executor.submit(stop_node, node) for node in DS.client_nodes]
node_cleanups = [executor.submit(stop_node, node) for node in DS.nomos_nodes + DS.client_nodes]
for cleanup in as_completed(node_cleanups):
result = cleanup.result()
if result is not None: