Create config.py

config.py

@@ -0,0 +1,23 @@
+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
+)