Skip to content

Commit

Permalink
PAN-2270: Point to certs (#148)
Browse files Browse the repository at this point in the history
* PAN-2270: Point to certs

* PAN-2270: Set proper path based on broker url
  • Loading branch information
jacekv authored Nov 19, 2024
1 parent 7d93ebb commit 2059a82
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion pantos/servicenode/celery.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

import amqp # type: ignore
import celery # type: ignore
import certifi # type: ignore
from pantos.common.logging import LogFile
from pantos.common.logging import LogFormat
from pantos.common.logging import initialize_logger
Expand Down Expand Up @@ -41,13 +42,16 @@ def is_main_module() -> bool:
_logger.info('Initializing the Celery application...')
initialize_application(False)

ca_certs = {} if config['celery']['broker'].startswith('amqp') else {
'ca_certs': certifi.where()
}
celery_app = celery.Celery(
'pantos.servicenode', broker=config['celery']['broker'],
backend=config['celery']['backend'], include=[
'pantos.common.blockchains.tasks',
'pantos.servicenode.business.transfers',
'pantos.servicenode.business.plugins'
])
], broker_use_ssl=ca_certs)
"""Celery application instance."""

# Additional Celery configuration
Expand Down

0 comments on commit 2059a82

Please sign in to comment.