@@ -297,31 +297,28 @@ impl<Signer: SignerTrait<T>, T: StacksMessageCodec + Clone + Send + Debug> RunLo
297
297
} ;
298
298
299
299
// Ensure that the stackerdb has been updated for the reward cycle before proceeding
300
- retry_with_exponential_backoff ( || {
301
- let last_calculated_reward_cycle = self
302
- . stacks_client
303
- . get_last_set_cycle ( )
304
- . map_err ( |e| backoff:: Error :: transient ( e. into ( ) ) ) ?;
305
- if last_calculated_reward_cycle < reward_cycle as u128 {
300
+ let last_calculated_reward_cycle =
301
+ self . stacks_client . get_last_set_cycle ( ) . map_err ( |e| {
306
302
warn ! (
307
- "Stackerdb has not been updated for reward cycle {reward_cycle}. Last calculated reward cycle is {last_calculated_reward_cycle}."
303
+ "Failed to fetch last calculated stackerdb cycle from stacks-node" ;
304
+ "reward_cycle" => reward_cycle,
305
+ "err" => ?e
308
306
) ;
309
- Err ( backoff:: Error :: transient (
310
- ConfigurationError :: StackerDBNotUpdated ,
311
- ) )
312
- } else {
313
- Ok ( ( ) )
314
- }
315
- } ) ?;
307
+ ConfigurationError :: StackerDBNotUpdated
308
+ } ) ?;
309
+ if last_calculated_reward_cycle < reward_cycle as u128 {
310
+ warn ! (
311
+ "Stackerdb has not been updated for reward cycle {reward_cycle}. Last calculated reward cycle is {last_calculated_reward_cycle}."
312
+ ) ;
313
+ return Err ( ConfigurationError :: StackerDBNotUpdated ) ;
314
+ }
316
315
317
- let signer_slot_ids = match self . get_parsed_signer_slots ( & self . stacks_client , reward_cycle)
318
- {
319
- Ok ( x) => x,
320
- Err ( e) => {
316
+ let signer_slot_ids = self
317
+ . get_parsed_signer_slots ( & self . stacks_client , reward_cycle)
318
+ . map_err ( |e| {
321
319
warn ! ( "Error while fetching stackerdb slots {reward_cycle}: {e:?}" ) ;
322
- return Err ( e. into ( ) ) ;
323
- }
324
- } ;
320
+ e
321
+ } ) ?;
325
322
let current_addr = self . stacks_client . get_signer_address ( ) ;
326
323
327
324
let Some ( signer_slot_id) = signer_slot_ids. get ( current_addr) else {
0 commit comments