Commit ca900aae authored by Markus Scheidgen's avatar Markus Scheidgen
Browse files

Log acks_late setting.

parent 01752c11
Pipeline #44727 passed with stages
in 24 minutes and 44 seconds
......@@ -42,6 +42,8 @@ if config.logstash.enabled:
@worker_process_init.connect
def setup(**kwargs):
infrastructure.setup()
utils.get_logger(__name__).info(
'celery configured with acks_late=%s' % str(config.celery.acks_late))
app = Celery('nomad.processing', broker=config.celery.broker_url)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment