diff options
Diffstat (limited to 'scenarios/fragments')
| -rw-r--r-- | scenarios/fragments/garage.py | 5 | ||||
| -rw-r--r-- | scenarios/fragments/minio.py | 8 |
2 files changed, 9 insertions, 4 deletions
diff --git a/scenarios/fragments/garage.py b/scenarios/fragments/garage.py index 8699655..84ca90a 100644 --- a/scenarios/fragments/garage.py +++ b/scenarios/fragments/garage.py @@ -38,9 +38,10 @@ if 'HOST' in env: config = storage_path / "garage.toml" env['GARAGE_CONFIG_FILE'] = str(config) -def deploy_coord(version=None, target=None): +def deploy_coord(): destroy() shared.log("start daemon") + shared.exec(f"{version['path']} --version") daemon() shared.log("discover nodes") connect() @@ -50,7 +51,7 @@ def deploy_coord(version=None, target=None): create_key() shared.log("ready") -def deploy_follow(version=None, target=None): +def deploy_follow(): destroy() shared.log("start daemon") daemon() diff --git a/scenarios/fragments/minio.py b/scenarios/fragments/minio.py index 1bdd882..8b0e970 100644 --- a/scenarios/fragments/minio.py +++ b/scenarios/fragments/minio.py @@ -113,8 +113,12 @@ def sync_on_bucket_up(): def sync_on_bucket_down(): while True: - if not client.bucket_exists("sync"): break - time.sleep(1) + try: + if not client.bucket_exists("sync"): break + time.sleep(1) + except Exception as e: + shared.log("the cluster is probably already half shutdown, so errors are expected ->", e) + break def delete_sync_bucket(): client.remove_bucket("sync") |