Update CI/CD to VPC

Author: immerSIR

app/services/celery/celery_config.py

@@ -1,6 +1,7 @@
 import logging
 import os
 from urllib.parse import quote_plus
+import re
 
 # Set up logging
 logging.basicConfig(level=logging.INFO)
@@ -42,14 +43,29 @@ def make_celery():
         redis_host = os.getenv('REDIS_HOST', 'localhost')
         redis_port = os.getenv('REDIS_PORT', '6379')
         redis_password = os.getenv('REDIS_PASSWORD')
-        
+
         if redis_password:
-            redis_password = quote_plus(redis_password)
-            redis_url = f'redis://:{redis_password}@{redis_host}:{redis_port}/0'
+            # Password exists, quote it and build URL
+            quoted_password = quote_plus(redis_password)
+            redis_url = f'redis://:{quoted_password}@{redis_host}:{redis_port}/0'
+            # Log with masking using the original password
+            logger.info(f"Configuring Celery with Redis URL: {redis_url.replace(redis_password, '***')}")
         else:
+            # No password, build simple URL
             redis_url = f'redis://{redis_host}:{redis_port}/0'
-
-    logger.info(f"Configuring Celery with Redis URL: {redis_url.replace(redis_password if redis_password else '', '***')}")
+            # Log without masking
+            logger.info(f"Configuring Celery with Redis URL: {redis_url}")
+    else:
+        # REDIS_URL was provided, try to mask if password pattern is detected
+        # Basic pattern matching for password in URL (adjust if needed)
+        match = re.match(r"redis://:(?P<password>[^@]+)@", redis_url)
+        if match:
+            password_to_mask = match.group("password")
+            masked_url = redis_url.replace(password_to_mask, "***")
+            logger.info(f"Configuring Celery with Redis URL: {masked_url}")
+        else:
+            # Assume no password or couldn't detect it, log as is
+            logger.info(f"Configuring Celery with Redis URL: {redis_url}")
 
     celery = Celery(
         'worker',