mirror of
https://github.com/langgenius/dify.git
synced 2026-04-24 12:55:49 +08:00
fix linter
This commit is contained in:
@ -253,10 +253,10 @@ class ApiTokenCache:
|
||||
# This is a safer approach when scope is unknown
|
||||
pattern = f"{CACHE_KEY_PREFIX}:*:{token}"
|
||||
try:
|
||||
keys = redis_client.keys(pattern)
|
||||
if keys:
|
||||
redis_client.delete(*keys)
|
||||
logger.info("Deleted %d cache entries for token", len(keys))
|
||||
keys_to_delete = list(redis_client.scan_iter(match=pattern))
|
||||
if keys_to_delete:
|
||||
redis_client.delete(*keys_to_delete)
|
||||
logger.info("Deleted %d cache entries for token", len(keys_to_delete))
|
||||
return True
|
||||
except Exception as e:
|
||||
logger.warning("Failed to delete token cache with pattern: %s", e)
|
||||
|
||||
@ -16,7 +16,7 @@ from models.model import ApiToken
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
@shared_task(queue="dataset", bind=True, max_retries=3)
|
||||
@shared_task(queue="dataset", bind=True)
|
||||
def update_api_token_last_used_task(self, token: str, scope: str | None, start_time_iso: str):
|
||||
"""
|
||||
Asynchronously update the last_used_at timestamp for an API token.
|
||||
|
||||
Reference in New Issue
Block a user