config.py

from async_framework import BrokerConfig, RedisConfig, RetryConfig

# Redis configuration for multiple queues
BROKER_CONFIG = BrokerConfig(
    redis=RedisConfig(
        host="localhost",
        port=6036,
        password="***************",
        db=0,
        connection_pool_size=10,
        #ssl=True  # Enable SSL for Redis Cloud connection
    ),
    retry=RetryConfig(
        max_retries=3,
        initial_delay=30.0,
        max_delay=90.0,
        backoff_factor=3.0
    ),
    num_workers=2,
    batch_size=5,
    polling_interval=1.0,
    metrics_port=8000  # Make sure this port is available
)