Skip to content

Commit

Permalink
cargo fmt fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
kate-goldenring committed Apr 9, 2021
1 parent 697c0e1 commit 3a01094
Showing 1 changed file with 9 additions and 3 deletions.
12 changes: 9 additions & 3 deletions controller/src/util/instance_action.rs
Original file line number Diff line number Diff line change
Expand Up @@ -116,23 +116,29 @@ async fn handle_instance(
"handle_instance - added Akri Instance {}: {:?}",
instance.metadata.name, instance.spec
);
handle_instance_change(&instance, &InstanceAction::Add, kube_interface).await.map_err(|e| anyhow::format_err!("{}", e))?;
handle_instance_change(&instance, &InstanceAction::Add, kube_interface)
.await
.map_err(|e| anyhow::format_err!("{}", e))?;
Ok(())
}
WatchEvent::Deleted(instance) => {
info!(
"handle_instance - deleted Akri Instance {}: {:?}",
instance.metadata.name, instance.spec
);
handle_instance_change(&instance, &InstanceAction::Remove, kube_interface).await.map_err(|e| anyhow::format_err!("{}", e))?;
handle_instance_change(&instance, &InstanceAction::Remove, kube_interface)
.await
.map_err(|e| anyhow::format_err!("{}", e))?;
Ok(())
}
WatchEvent::Modified(instance) => {
info!(
"handle_instance - modified Akri Instance {}: {:?}",
instance.metadata.name, instance.spec
);
handle_instance_change(&instance, &InstanceAction::Update, kube_interface).await.map_err(|e| anyhow::format_err!("{}", e))?;
handle_instance_change(&instance, &InstanceAction::Update, kube_interface)
.await
.map_err(|e| anyhow::format_err!("{}", e))?;
Ok(())
}
WatchEvent::Error(ref e) => Err(anyhow::format_err!(
Expand Down

0 comments on commit 3a01094

Please sign in to comment.