diff --git a/compute_worker/celery_config.py b/compute_worker/celery_config.py index 1a3f86d83..674a3ae60 100644 --- a/compute_worker/celery_config.py +++ b/compute_worker/celery_config.py @@ -1,8 +1,11 @@ import os - +import ssl broker_url = os.environ.get('BROKER_URL') -broker_use_ssl = os.environ.get('BROKER_USE_SSL', False) +if os.environ.get('BROKER_USE_SSL', False): + broker_use_ssl = { + "cert_reqs": ssl.CERT_NONE, + } worker_concurrency = 1 worker_prefetch_multiplier = 1 task_acks_late = True