From b70cf6d7f741c374492daba07e6c3851fb3702c0 Mon Sep 17 00:00:00 2001 From: Mark Murnane Date: Tue, 1 Aug 2023 23:30:11 -0400 Subject: [PATCH] Removing broker_url hack --- uber/tasks/__init__.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/uber/tasks/__init__.py b/uber/tasks/__init__.py index 880754e8c..6be64db68 100644 --- 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):