@@ -539,26 +539,19 @@ impl WorkerContext {
539
539
vec ! [ Value :: from_bytes( worker_binding. as_ref( ) . unwrap( ) ) ] ,
540
540
) ;
541
541
let stake_onchain: Option < u128 > = fetch_storage_bytes ( & api, & stake_query) . await ?;
542
- match stake_onchain {
543
- Some ( onchain_stake) => {
544
- info ! (
545
- "Stake: {:?}, {:?} on-chain" ,
546
- & worker. stake. parse:: <u128 >( ) . unwrap( ) ,
547
- & onchain_stake
548
- ) ;
549
- match onchain_stake {
550
- onchain_stake if onchain_stake < worker. stake . parse :: < u128 > ( ) . unwrap ( ) => {
551
- set_worker_message ! ( c, "Adjusting on-chain stake..." ) ;
552
- txm. clone ( ) . restart_computing ( pid, pubkey, worker. stake ) . await ?;
553
- Self :: set_state ( c. clone ( ) , WorkerLifecycleState :: Working ) . await ;
554
- }
555
- onchain_stake if onchain_stake > worker. stake . parse :: < u128 > ( ) . unwrap ( ) => {
556
- set_worker_message ! ( c, "Error on-chain stake higher, than configured..." ) ;
557
- }
558
- _ => ( ) ,
559
- }
542
+ if let Some ( onchain_stake) = stake_onchain {
543
+ info ! ( "Stake: {:?}, {:?} on-chain" , & worker. stake. parse:: <u128 >( ) . unwrap( ) , & onchain_stake) ;
544
+ match onchain_stake {
545
+ onchain_stake if onchain_stake < worker. stake . parse :: < u128 > ( ) . unwrap ( ) => {
546
+ set_worker_message ! ( c, "Adjusting on-chain stake..." ) ;
547
+ txm. clone ( ) . restart_computing ( pid, pubkey, worker. stake ) . await ?;
548
+ Self :: set_state ( c. clone ( ) , WorkerLifecycleState :: Working ) . await ;
549
+ }
550
+ onchain_stake if onchain_stake > worker. stake . parse :: < u128 > ( ) . unwrap ( ) => {
551
+ set_worker_message ! ( c, "Error on-chain stake higher, than configured..." ) ;
552
+ }
553
+ _ => ( ) ,
560
554
}
561
- None => ( ) ,
562
555
}
563
556
first_run = false ;
564
557
}
0 commit comments