Removing broker_url hack

magfest · Aug 2, 2023 · b70cf6d · b70cf6d
1 parent 482368a
commit b70cf6d
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/uber/tasks/__init__.py b/uber/tasks/__init__.py
@@ -14,12 +14,9 @@
 celery.conf.update(config_dict['celery'])
 
 broker_url = config_dict['secret']['broker_url']
-if broker_url.startswith("amqps://"):
-    celery.conf.update(broker_use_ssl=True)
-    broker_url = broker_url.replace("amqps://", "amqp://")
 
 celery.conf.update(broker_url=broker_url)
-celery.conf.update(result_backend=broker_url.replace("amqp://", "rpc://"))
+celery.conf.update(result_backend=broker_url.replace("amqps://", "rpc://"))
 celery.conf.update(task_ignore_result=True)
 
 def celery_on_startup(fn, *args, **kwargs):