1 files changed, 7 insertions, 7 deletions

diff --git a/plugins/c8y_log_plugin/src/main.rs b/plugins/c8y_log_plugin/src/main.rs
index b5a7799e..169e00fc 100644
--- a/plugins/c8y_log_plugin/src/main.rs
+++ b/plugins/c8y_log_plugin/src/main.rs
@@ -79,7 +79,7 @@ pub async fn create_http_client(
     tedge_config: &TEdgeConfig,
 ) -> Result<JwtAuthHttpProxy, anyhow::Error> {
     let mut http_proxy = JwtAuthHttpProxy::try_new(tedge_config).await?;
-    let () = http_proxy.init().await?;
+    http_proxy.init().await?;
     Ok(http_proxy)
 }
 
@@ -93,7 +93,7 @@ async fn run(
 
     let health_check_topics = health_check_topics("c8y-log-plugin");
     let config_file_path = config_dir.join(config_file_name);
-    let () = handle_dynamic_log_type_update(&plugin_config, mqtt_client).await?;
+    handle_dynamic_log_type_update(&plugin_config, mqtt_client).await?;
 
     let fs_notification_stream = fs_notify_stream(&[(
         config_dir,
@@ -116,7 +116,7 @@ async fn run(
                 match mask {
                     FileEvent::Created | FileEvent::Deleted | FileEvent::Modified => {
                         plugin_config = read_log_config(&config_file_path);
-                        let () = handle_dynamic_log_type_update(&plugin_config, mqtt_client).await?;
+                        handle_dynamic_log_type_update(&plugin_config, mqtt_client).await?;
                     }
                 }
             }
@@ -134,7 +134,7 @@ pub async fn process_mqtt_message(
 ) -> Result<(), anyhow::Error> {
     if is_c8y_bridge_up(&message) {
         let plugin_config = read_log_config(config_file);
-        let () = handle_dynamic_log_type_update(&plugin_config, mqtt_client).await?;
+        handle_dynamic_log_type_update(&plugin_config, mqtt_client).await?;
     } else if health_check_topics.accept(&message) {
         send_health_status(&mut mqtt_client.published, "c8y-log-plugin").await;
     } else if let Ok(payload) = message.payload_str() {
@@ -192,7 +192,7 @@ async fn main() -> Result<(), anyhow::Error> {
     let logs_dir = PathBuf::from(logs_dir.to_string());
 
     if config_plugin_opt.init {
-        let () = init(&config_plugin_opt.config_dir, &logs_dir)?;
+        init(&config_plugin_opt.config_dir, &logs_dir)?;
         return Ok(());
     }
 
@@ -200,7 +200,7 @@ async fn main() -> Result<(), anyhow::Error> {
     let mut mqtt_client = create_mqtt_client(&tedge_config).await?;
     let mut http_client = create_http_client(&tedge_config).await?;
 
-    let () = run(
+    run(
         &config_dir,
         DEFAULT_PLUGIN_CONFIG_FILE,
         &mut mqtt_client,
@@ -212,7 +212,7 @@ async fn main() -> Result<(), anyhow::Error> {
 
 fn init(config_dir: &Path, logs_dir: &Path) -> Result<(), anyhow::Error> {
     info!("Creating supported operation files");
-    let () = create_init_logs_directories_and_files(config_dir, logs_dir)?;
+    create_init_logs_directories_and_files(config_dir, logs_dir)?;
     Ok(())
 }