@@ -197,20 +197,16 @@ async fn validator_tick<A: Adapter + 'static>(
197
197
let duration = Duration :: from_millis ( config. validator_tick_timeout as u64 ) ;
198
198
199
199
match channel. spec . validators . find ( & whoami) {
200
- SpecValidator :: Leader ( _) => {
201
- match timeout ( duration, leader:: tick ( & sentry) ) . await {
202
- Err ( e) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
203
- Ok ( Err ( e) ) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
204
- _ => ( )
205
- }
206
- }
207
- SpecValidator :: Follower ( _) => {
208
- match timeout ( duration, follower:: tick ( & sentry) ) . await {
209
- Err ( e) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
210
- Ok ( Err ( e) ) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
211
- _ => ( )
212
- }
213
- }
200
+ SpecValidator :: Leader ( _) => match timeout ( duration, leader:: tick ( & sentry) ) . await {
201
+ Err ( e) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
202
+ Ok ( Err ( e) ) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
203
+ _ => ( ) ,
204
+ } ,
205
+ SpecValidator :: Follower ( _) => match timeout ( duration, follower:: tick ( & sentry) ) . await {
206
+ Err ( e) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
207
+ Ok ( Err ( e) ) => return Err ( ValidatorWorkerError :: Failed ( e. to_string ( ) ) ) ,
208
+ _ => ( ) ,
209
+ } ,
214
210
SpecValidator :: None => {
215
211
return Err ( ValidatorWorkerError :: Failed (
216
212
"validatorTick: processing a channel where we are not validating" . to_string ( ) ,
0 commit comments