handle error: storage belongs to different cluster

Author: BalabaDmitri

tests/integration/ha_tests/test_self_healing.py

@@ -80,7 +80,7 @@ async def test_build_and_deploy(ops_test: OpsTest) -> None:
         async with ops_test.fast_forward():
             await ops_test.model.deploy(
                 charm,
-                num_units=3,
+                num_units=1,
                 series=CHARM_SERIES,
                 storage={"pgdata": {"pool": "lxd-btrfs", "size": 2048}},
                 config={"profile": "testing"},
@@ -617,14 +617,19 @@ async def test_deploy_zero_units(ops_test: OpsTest, charm):
     await add_unit_with_storage(ops_test, app=app, storage=primary_storage)
     await ops_test.model.wait_for_idle(apps=[APP_NAME, APPLICATION_NAME], status="active", timeout=1500)
 
+    connection_string, _ = await get_db_connection(ops_test, dbname=dbname)
+    logger.info("checking whether writes are increasing")
+    await are_writes_increasing(ops_test)
+
+    logger.info("check test database data")
+    await validate_test_data(connection_string)
+
     logger.info("scaling database to tow unit using foreign cluster")
     new_unit = await add_unit_with_storage(ops_test, app=app, storage=second_storage, is_blocked=True)
 
     logger.info(f"remove unit {new_unit.name} with storage from application {SECOND_APPLICATION}")
     await ops_test.model.destroy_units(new_unit.name)
 
-    connection_string, _ = await get_db_connection(ops_test, dbname=dbname)
-    logger.info("checking whether writes are increasing")
     await are_writes_increasing(ops_test)
 
     logger.info("check test database data")