Skip to content
Snippets Groups Projects
Commit 737df390 authored by Robert Latta's avatar Robert Latta
Browse files

Merge branch 'feature/DBOARD3-752' into 'develop'

Add redis auth credentials to celery backend config.

See merge request !12
parents 0240d080 76329478
No related branches found
No related tags found
1 merge request!12Add redis auth credentials to celery backend config.
...@@ -34,6 +34,7 @@ redis_socket_timeout = params.get( ...@@ -34,6 +34,7 @@ redis_socket_timeout = params.get(
_broker_hostname = params['hostname'] _broker_hostname = params['hostname']
_broker_port = params['port'] _broker_port = params['port']
_broker_password = params.get('password')
_broker_db_index = params.get('celery-db-index', DEFAULT_CELERY_DB_INDEX) _broker_db_index = params.get('celery-db-index', DEFAULT_CELERY_DB_INDEX)
...@@ -41,9 +42,14 @@ if ':' in _broker_hostname: ...@@ -41,9 +42,14 @@ if ':' in _broker_hostname:
# assume this means hostname is an ipv6 address # assume this means hostname is an ipv6 address
_broker_hostname = f'[{_broker_hostname}]' _broker_hostname = f'[{_broker_hostname}]'
broker_url = result_backend = (f'{_broker_scheme}://{_broker_hostname}' broker_url = result_backend = (
f':{_broker_port}/{_broker_db_index}') f'{_broker_scheme}://'
logger.debug('broker_url: %r' % broker_url) f'{"" if not _broker_password else f":{_broker_password}@"}'
f'{_broker_hostname}:{_broker_port}/{_broker_db_index}'
)
logger.debug('broker_url: %r' % broker_url.replace(_broker_password, '***')
if _broker_password else broker_url)
task_eager_propagates = True task_eager_propagates = True
task_track_started = True task_track_started = True
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment