Modify error comment to specify controller and agent restarting

project-akri · Sep 10, 2021 · e8c59a9 · e8c59a9
1 parent cb0b9ba
commit e8c59a9
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/agent/src/util/config_action.rs b/agent/src/util/config_action.rs
@@ -164,7 +164,7 @@ async fn handle_config(
                 info!("handle_config - watcher started");
             } else {
                 return Err(anyhow::anyhow!(
-                    "Configuration watcher restarted - throwing error"
+                    "Configuration watcher restarted - throwing error to restart agent"
                 ));
             }
         }

diff --git a/controller/src/util/instance_action.rs b/controller/src/util/instance_action.rs
@@ -125,7 +125,7 @@ async fn handle_instance(
                 info!("handle_instance - watcher started");
             } else {
                 return Err(anyhow::anyhow!(
-                    "Instance watcher restarted - throwing error"
+                    "Instance watcher restarted - throwing error to restart controller"
                 ));
             }
         }

diff --git a/controller/src/util/node_watcher.rs b/controller/src/util/node_watcher.rs
@@ -119,7 +119,9 @@ impl NodeWatcher {
                 if *first_event {
                     info!("handle_node - watcher started");
                 } else {
-                    return Err(anyhow::anyhow!("Node watcher restarted - throwing error"));
+                    return Err(anyhow::anyhow!(
+                        "Node watcher restarted - throwing error to restart controller"
+                    ));
                 }
             }
         };

diff --git a/controller/src/util/pod_watcher.rs b/controller/src/util/pod_watcher.rs
@@ -168,7 +168,9 @@ impl BrokerPodWatcher {
                         pods
                     );
                 } else {
-                    return Err(anyhow::anyhow!("Pod watcher restarted - throwing error"));
+                    return Err(anyhow::anyhow!(
+                        "Pod watcher restarted - throwing error to restart controller"
+                    ));
                 }
             }
         };