@@ -18,7 +18,7 @@ use kube::{
1818 Api , Client , ResourceExt ,
1919 api:: { Patch , PatchParams } ,
2020} ;
21- use snafu:: { ResultExt , Snafu , ensure } ;
21+ use snafu:: { ResultExt , Snafu } ;
2222use tokio:: sync:: oneshot;
2323use tracing:: instrument;
2424
@@ -27,9 +27,6 @@ use crate::WebhookServerOptions;
2727
2828#[ derive( Debug , Snafu ) ]
2929pub enum ConversionWebhookError {
30- #[ snafu( display( "failed to send initial CRD reconcile heartbeat" ) ) ]
31- SendInitialReconcileHeartbeat ,
32-
3330 #[ snafu( display( "failed to patch CRD {crd_name:?}" ) ) ]
3431 PatchCrd {
3532 source : kube:: Error ,
@@ -262,10 +259,9 @@ where
262259 // After the reconciliation of the CRDs, the initial reconcile heartbeat is sent out
263260 // via the oneshot channel.
264261 if let Some ( initial_reconcile_tx) = self . initial_reconcile_tx . take ( ) {
265- ensure ! (
266- initial_reconcile_tx. send( ( ) ) . is_ok( ) ,
267- SendInitialReconcileHeartbeatSnafu
268- ) ;
262+ // This call will (only) error in case the receiver is dropped, so we need to ignore
263+ // failures.
264+ let _ = initial_reconcile_tx. send ( ( ) ) ;
269265 }
270266
271267 Ok ( ( ) )
0 commit comments