from redis.lock import Lock from copy_auth0_logs_to_cloudwatch import constants def get_key(key: str) -> str: """Compose a Redis key. Args: key (str): Key. Returns: str: Complete key constructed by concatenated prefix + key. """ return f'{constants.APP_NAME}/{key}' def get_redis_lock(redis_client) -> Lock: """Get redis lock""" return redis_client.lock(get_key('lock'), timeout=constants.REDIS_LOCK_TTL)