Release 20250727

[MistEO]

No description provided.

[Copilot]

Pull Request Overview

This PR implements a Redis pub/sub system for cache invalidation and introduces Redis client functionality. The changes add the ability to subscribe to cache eviction messages and automatically clear both plan and contact caches when triggered.

• Adds Redis client with pub/sub capabilities for cache management
• Implements cache clearing functions for plan and contact data
• Integrates cache subscriber into the FastAPI application lifecycle

Reviewed Changes

Copilot reviewed 7 out of 9 changed files in this pull request and generated 4 comments.

Show a summary per file

File	Description
src/redis/subscriber.py	Implements cache clearing subscriber that listens for eviction messages
src/redis/client.py	Provides Redis client with connection, publish, and subscribe functionality
src/redis/init.py	Exports Redis module components
src/plan/cache.py	Adds cache clearing function for plan data
src/contact_us/init.py	Adds cache clearing function and renames cache getter for consistency
src/config/init.py	Adds Redis configuration settings
main.py	Integrates Redis subscriber into application lifecycle and fixes import case

[Copilot]

The finally block checks rds.pubsub but should check pubsub (the local variable from line 12). This could cause the unsubscribe to not execute when rds.pubsub is None but pubsub exists.

Suggested change

	if rds.pubsub:
	await rds.pubsub.unsubscribe(channel)
	if pubsub:
	await pubsub.unsubscribe(channel)

[Copilot]

This should use the local pubsub variable instead of rds.pubsub to ensure proper cleanup of the subscription created in this function.

Suggested change

	if rds.pubsub:
	await rds.pubsub.unsubscribe(channel)
	if pubsub:
	await pubsub.unsubscribe(channel)

[Copilot]

The created task is not stored or awaited, which means there's no way to handle exceptions or ensure proper cleanup. Consider storing the task reference for better lifecycle management.

Suggested change

	asyncio.create_task(cache_clear_subscriber())
	task = asyncio.create_task(cache_clear_subscriber())
	task.add_done_callback(lambda t: logger.error(f"Task cache_clear_subscriber failed: {t.exception()}") if t.exception() else logger.info("Task cache_clear_subscriber completed successfully"))

[Copilot]

[nitpick] Use f-string formatting instead of .format() for consistency with the rest of the codebase (as seen in lines 26 and 30).

Suggested change

	logger.info("evict message received: {}".format(message))
	logger.info(f"evict message received: {message}")