skullbite/cartridges
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

✨ Added Steam API rate limiter

Browse Source
This commit is contained in:
GeoffreyCoulaud
2023-06-03 18:49:47 +02:00
parent 216c3f5dae
commit 6f77e0d30d
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/store/managers/manager.py
View File

@@ -63,7 +63,9 @@ class Manager:
# Handle unretryable errors # Handle unretryable errors
log_args = (type(error).__name__, self.name, game.name, game.game_id) log_args = (type(error).__name__, self.name, game.name, game.game_id)
if type(error) not in self.retryable_on: if type(error) not in self.retryable_on:
logging.error("Unretryable %s in %s for %s (%s)", *log_args) logging.error(
"Unretryable %s in %s for %s (%s)", *log_args, exc_info=error
)
self.report_error(error) self.report_error(error)
break break
# Handle being out of retries # Handle being out of retries

3
src/utils/rate_limiter.py
View File

@@ -43,9 +43,10 @@ class TokenBucketRateLimiter(AbstractContextManager):
if refill_spacing_seconds is not None: if refill_spacing_seconds is not None:
self.REFILL_SPACING_SECONDS = refill_spacing_seconds self.REFILL_SPACING_SECONDS = refill_spacing_seconds
# Create locks # Create synchro data
self.__n_tokens_lock = Lock() self.__n_tokens_lock = Lock()
self.queue_lock = Lock() self.queue_lock = Lock()
self.queue = deque()
# Initialize the number of tokens in the bucket # Initialize the number of tokens in the bucket
self.bucket = BoundedSemaphore(self.MAX_TOKENS) self.bucket = BoundedSemaphore(self.MAX_TOKENS)