Anish-530 commited on
Commit
26793ce
·
1 Parent(s): 96c41f2

Fix Celery Upstash Redis SSL compatibility

Browse files
Files changed (1) hide show
  1. backend/app/worker/celery_app.py +7 -2
backend/app/worker/celery_app.py CHANGED
@@ -1,10 +1,15 @@
1
  from celery import Celery
2
  from app.core.config import settings
3
 
 
 
 
 
 
4
  celery_app = Celery(
5
  "worker",
6
- broker=settings.REDIS_URL,
7
- backend=settings.REDIS_URL,
8
  include=["app.worker.tasks"]
9
  )
10
 
 
1
  from celery import Celery
2
  from app.core.config import settings
3
 
4
+ redis_url = settings.REDIS_URL
5
+ if redis_url.startswith("rediss://") and "ssl_cert_reqs=" not in redis_url:
6
+ delimiter = "&" if "?" in redis_url else "?"
7
+ redis_url = f"{redis_url}{delimiter}ssl_cert_reqs=CERT_NONE"
8
+
9
  celery_app = Celery(
10
  "worker",
11
+ broker=redis_url,
12
+ backend=redis_url,
13
  include=["app.worker.tasks"]
14
  )
15