From 7b454c4bbc97594de49b4ba62c472fcd44ea55dc Mon Sep 17 00:00:00 2001 From: sugaf1204 Date: Sun, 28 Jul 2024 18:09:45 +0000 Subject: [PATCH] Fix bug#114311 - on_startup process fails --- .../controller/innodbcluster/operator_cluster.py | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/mysqloperator/controller/innodbcluster/operator_cluster.py b/mysqloperator/controller/innodbcluster/operator_cluster.py index a8596f8c..b09dde40 100644 --- a/mysqloperator/controller/innodbcluster/operator_cluster.py +++ b/mysqloperator/controller/innodbcluster/operator_cluster.py @@ -43,8 +43,11 @@ def on_group_view_change(cluster: InnoDBCluster, members: list[tuple], view_id_c def monitor_existing_clusters(clusters: List[InnoDBCluster], logger: Logger) -> None: for cluster in clusters: if cluster.get_create_time(): - g_group_monitor.monitor_cluster( - cluster, on_group_view_change, logger) + try: + g_group_monitor.monitor_cluster( + cluster, on_group_view_change, logger) + except Exception as exc: + logger.warn(f"Error while monitoring {cluster.namespace}/{cluster.name}: {exc}") def ensure_backup_schedules_use_current_image(clusters: List[InnoDBCluster], logger: Logger) -> None: @@ -58,9 +61,12 @@ def ensure_backup_schedules_use_current_image(clusters: List[InnoDBCluster], log def ensure_router_accounts_are_uptodate(clusters: List[InnoDBCluster], logger: Logger) -> None: for cluster in clusters: - router_objects.update_router_account(cluster, - lambda: logger.warning(f"Cluster {cluster.namespace}/{cluster.name} unreachable"), - logger) + try: + router_objects.update_router_account(cluster, + lambda: logger.warning(f"Cluster {cluster.namespace}/{cluster.name} unreachable"), + logger) + except Exception as exc: + logger.warn(f"Error while ensuring router accounts are up-to-date for {cluster.namespace}/{cluster.name}: {exc}") def ignore_404(f) -> Any: