fixup! Additional fixes

This commit is contained in:
Xiaoge Su 2023-03-20 16:30:17 -07:00
parent 819f0427b3
commit 39369e63c2
3 changed files with 5 additions and 7 deletions

View File

@ -4,4 +4,4 @@ set -e
set -o pipefail
# It is necessary to tee to output.log in case timeout happens
python3 ./binding_test.py --stop-at-failure 10 --fdbserver-path $(pwd)/fdbserver --fdbcli-path $(pwd)/fdbcli --libfdb-path $(pwd) --num-ops 1000 --num-hca-ops 100 --concurrency 5 --test-timeout 60 --random | tee output.log
python3 ./binding_test.py --stop-at-failure 10 --fdbserver-path $(pwd)/fdbserver --fdbcli-path $(pwd)/fdbcli --libfdb-path $(pwd) --num-ops 1000 --num-hca-ops 100 --concurrency 5 --test-timeout 60 --random 2>&1 | tee output.log

View File

@ -59,7 +59,7 @@ def _setup_logs(log_level: int = logging.INFO):
lib_logger.addHandler(stdout_handler)
lib_logger.setLevel(log_level)
local_cluster_logger = logging.getLogger("local_cluster")
local_cluster_logger = logging.getLogger("lib.local_cluster")
local_cluster_logger.addHandler(stdout_handler)
local_cluster_logger.setLevel(log_level)
@ -405,7 +405,6 @@ def main() -> int:
timeout=args.test_timeout,
)
logger.info(f"Binding test start")
num_failures = asyncio.run(
run_binding_tests(test_set, args.num_cycles, args.stop_at_failure, args.random)
)

View File

@ -71,21 +71,20 @@ class WorkDirectory:
"""Set up the directories"""
if self._base_directory is None:
self._base_directory = tempfile.mkdtemp()
logger.debug(f"Work directory {self.base_directory}")
assert self.base_directory is not None
assert self.data_directory is not None
assert self.log_directory is not None
logger.debug(f"Work directory {self.base_directory}")
self._data_directory = os.path.join(
self._base_directory, self._data_directory_rel
)
assert self.data_directory is not None
os.makedirs(self.data_directory, exist_ok=True)
logger.debug(f"Created data directory {self.data_directory}")
self._log_directory = os.path.join(
self._base_directory, self._log_directory_rel
)
assert self.log_directory is not None
os.makedirs(self.log_directory, exist_ok=True)
os.chdir(self.base_directory)