triangle strange bug
diff --git a/wally/suits/io/fio.py b/wally/suits/io/fio.py
index 275c1ed..1a3e846 100644
--- a/wally/suits/io/fio.py
+++ b/wally/suits/io/fio.py
@@ -3,6 +3,7 @@
import json
import stat
import random
+import shutil
import os.path
import logging
import datetime
@@ -668,7 +669,8 @@
for idx in range(max_retr):
try:
intervals = list(pool.map(func, self.config.nodes))
- break
+ if None not in intervals:
+ break
except (EnvironmentError, SSHException) as exc:
logger.exception("During fio run")
if idx == max_retr - 1:
@@ -814,6 +816,10 @@
arch_name = self.join_remote('wally_result.tar.gz')
tmp_dir = os.path.join(self.config.log_directory, 'tmp_' + conn_id)
+
+ if os.path.exists(tmp_dir):
+ shutil.rmtree(tmp_dir)
+
os.mkdir(tmp_dir)
loc_arch_name = os.path.join(tmp_dir, 'wally_result.{0}.tar.gz'.format(conn_id))
file_full_names = " ".join(all_files)
@@ -824,7 +830,13 @@
pass
with node.connection.open_sftp() as sftp:
- exit_code = read_from_remote(sftp, self.exit_code_file)
+ try:
+ exit_code = read_from_remote(sftp, self.exit_code_file)
+ except IOError:
+ logger.error("No exit code file found on %s. Looks like process failed to start",
+ conn_id)
+ return None
+
err_out = read_from_remote(sftp, self.err_out_file)
exit_code = exit_code.strip()