Skip to content

Commit

Permalink
tweak stall time/log
Browse files Browse the repository at this point in the history
  • Loading branch information
alexdunnjpl committed Oct 24, 2024
1 parent 0649a2c commit 3090b5f
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/pds/registrysweepers/reindexer/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -282,8 +282,8 @@ def get_updated_hits_count():
hits_stall_tolerance = math.ceil(0.05 * batch_size_limit)
stall_while_hits_exceed_count = expected_remaining_hits + hits_stall_tolerance
while get_updated_hits_count() > stall_while_hits_exceed_count:
stall_period = timedelta(seconds=10)
logging.info(f'Many updates pending, waiting {stall_period.total_seconds()}s until hits count falls below {stall_while_hits_exceed_count} (expected {expected_remaining_hits}, got {get_updated_hits_count()})')
stall_period = timedelta(seconds=60)
logging.info(f'Many updates pending, waiting {int(stall_period.total_seconds())}s until hits count falls below {stall_while_hits_exceed_count} (expected {expected_remaining_hits}, got {get_updated_hits_count()})')
sleep(stall_period.total_seconds())

mapping_field_types_by_field_name = get_mapping_field_types_by_field_name(client, products_index_name)
Expand Down

0 comments on commit 3090b5f

Please sign in to comment.