Show More
@@ -314,14 +314,12 b' allow_custom_hooks_settings = True' | |||||
314 | #################################### |
|
314 | #################################### | |
315 |
|
315 | |||
316 | use_celery = false |
|
316 | use_celery = false | |
317 | broker.host = localhost |
|
317 | ||
318 | broker.vhost = rabbitmqhost |
|
318 | ## Example: connect to the virtual host 'rabbitmqhost' on localhost as rabbitmq: | |
319 | broker.port = 5672 |
|
319 | broker.url = amqp://rabbitmq:qewqew@localhost:5672/rabbitmqhost | |
320 | broker.user = rabbitmq |
|
|||
321 | broker.password = qweqwe |
|
|||
322 |
|
320 | |||
323 | celery.imports = kallithea.lib.celerylib.tasks |
|
321 | celery.imports = kallithea.lib.celerylib.tasks | |
324 |
|
322 | celery.accept.content = pickle | ||
325 | celery.result.backend = amqp |
|
323 | celery.result.backend = amqp | |
326 | celery.result.dburi = amqp:// |
|
324 | celery.result.dburi = amqp:// | |
327 | celery.result.serialier = json |
|
325 | celery.result.serialier = json | |
@@ -330,11 +328,9 b' celery.result.serialier = json' | |||||
330 | #celery.amqp.task.result.expires = 18000 |
|
328 | #celery.amqp.task.result.expires = 18000 | |
331 |
|
329 | |||
332 | celeryd.concurrency = 2 |
|
330 | celeryd.concurrency = 2 | |
333 | #celeryd.log.file = celeryd.log |
|
|||
334 | celeryd.log.level = DEBUG |
|
|||
335 | celeryd.max.tasks.per.child = 1 |
|
331 | celeryd.max.tasks.per.child = 1 | |
336 |
|
332 | |||
337 | ## tasks will never be sent to the queue, but executed locally instead. |
|
333 | ## If true, tasks will never be sent to the queue, but executed locally instead. | |
338 | celery.always.eager = false |
|
334 | celery.always.eager = false | |
339 |
|
335 | |||
340 | #################################### |
|
336 | #################################### |
@@ -311,14 +311,12 b' allow_custom_hooks_settings = True' | |||||
311 | <%text>####################################</%text> |
|
311 | <%text>####################################</%text> | |
312 |
|
312 | |||
313 | use_celery = false |
|
313 | use_celery = false | |
314 | broker.host = localhost |
|
314 | ||
315 | broker.vhost = rabbitmqhost |
|
315 | <%text>## Example: connect to the virtual host 'rabbitmqhost' on localhost as rabbitmq:</%text> | |
316 | broker.port = 5672 |
|
316 | broker.url = amqp://rabbitmq:qewqew@localhost:5672/rabbitmqhost | |
317 | broker.user = rabbitmq |
|
|||
318 | broker.password = qweqwe |
|
|||
319 |
|
317 | |||
320 | celery.imports = kallithea.lib.celerylib.tasks |
|
318 | celery.imports = kallithea.lib.celerylib.tasks | |
321 |
|
319 | celery.accept.content = pickle | ||
322 | celery.result.backend = amqp |
|
320 | celery.result.backend = amqp | |
323 | celery.result.dburi = amqp:// |
|
321 | celery.result.dburi = amqp:// | |
324 | celery.result.serialier = json |
|
322 | celery.result.serialier = json | |
@@ -327,11 +325,9 b' celery.result.serialier = json' | |||||
327 | #celery.amqp.task.result.expires = 18000 |
|
325 | #celery.amqp.task.result.expires = 18000 | |
328 |
|
326 | |||
329 | celeryd.concurrency = 2 |
|
327 | celeryd.concurrency = 2 | |
330 | #celeryd.log.file = celeryd.log |
|
|||
331 | celeryd.log.level = DEBUG |
|
|||
332 | celeryd.max.tasks.per.child = 1 |
|
328 | celeryd.max.tasks.per.child = 1 | |
333 |
|
329 | |||
334 | <%text>## tasks will never be sent to the queue, but executed locally instead.</%text> |
|
330 | <%text>## If true, tasks will never be sent to the queue, but executed locally instead.</%text> | |
335 | celery.always.eager = false |
|
331 | celery.always.eager = false | |
336 |
|
332 | |||
337 | <%text>####################################</%text> |
|
333 | <%text>####################################</%text> |
@@ -307,14 +307,12 b' allow_custom_hooks_settings = True' | |||||
307 | #################################### |
|
307 | #################################### | |
308 |
|
308 | |||
309 | use_celery = false |
|
309 | use_celery = false | |
310 | broker.host = localhost |
|
310 | ||
311 | broker.vhost = rabbitmqhost |
|
311 | ## Example: connect to the virtual host 'rabbitmqhost' on localhost as rabbitmq: | |
312 | broker.port = 5672 |
|
312 | broker.url = amqp://rabbitmq:qewqew@localhost:5672/rabbitmqhost | |
313 | broker.user = rabbitmq |
|
|||
314 | broker.password = qweqwe |
|
|||
315 |
|
313 | |||
316 | celery.imports = kallithea.lib.celerylib.tasks |
|
314 | celery.imports = kallithea.lib.celerylib.tasks | |
317 |
|
315 | celery.accept.content = pickle | ||
318 | celery.result.backend = amqp |
|
316 | celery.result.backend = amqp | |
319 | celery.result.dburi = amqp:// |
|
317 | celery.result.dburi = amqp:// | |
320 | celery.result.serialier = json |
|
318 | celery.result.serialier = json | |
@@ -323,11 +321,9 b' celery.result.serialier = json' | |||||
323 | #celery.amqp.task.result.expires = 18000 |
|
321 | #celery.amqp.task.result.expires = 18000 | |
324 |
|
322 | |||
325 | celeryd.concurrency = 2 |
|
323 | celeryd.concurrency = 2 | |
326 | #celeryd.log.file = celeryd.log |
|
|||
327 | celeryd.log.level = DEBUG |
|
|||
328 | celeryd.max.tasks.per.child = 1 |
|
324 | celeryd.max.tasks.per.child = 1 | |
329 |
|
325 | |||
330 | ## tasks will never be sent to the queue, but executed locally instead. |
|
326 | ## If true, tasks will never be sent to the queue, but executed locally instead. | |
331 | celery.always.eager = false |
|
327 | celery.always.eager = false | |
332 |
|
328 | |||
333 | #################################### |
|
329 | #################################### |
@@ -7,7 +7,7 b' from pylons import config' | |||||
7 | to_pylons = lambda x: x.replace('_', '.').lower() |
|
7 | to_pylons = lambda x: x.replace('_', '.').lower() | |
8 | to_celery = lambda x: x.replace('.', '_').upper() |
|
8 | to_celery = lambda x: x.replace('.', '_').upper() | |
9 |
|
9 | |||
10 | LIST_PARAMS = """CELERY_IMPORTS ADMINS ROUTES""".split() |
|
10 | LIST_PARAMS = """CELERY_IMPORTS ADMINS ROUTES CELERY_ACCEPT_CONTENT""".split() | |
11 |
|
11 | |||
12 |
|
12 | |||
13 | class PylonsSettingsProxy(object): |
|
13 | class PylonsSettingsProxy(object): |
@@ -316,14 +316,12 b' allow_custom_hooks_settings = True' | |||||
316 | #################################### |
|
316 | #################################### | |
317 |
|
317 | |||
318 | use_celery = false |
|
318 | use_celery = false | |
319 | broker.host = localhost |
|
319 | ||
320 | broker.vhost = rabbitmqhost |
|
320 | ## Example: connect to the virtual host 'rabbitmqhost' on localhost as rabbitmq: | |
321 | broker.port = 5672 |
|
321 | broker.url = amqp://rabbitmq:qewqew@localhost:5672/rabbitmqhost | |
322 | broker.user = rabbitmq |
|
|||
323 | broker.password = qweqwe |
|
|||
324 |
|
322 | |||
325 | celery.imports = kallithea.lib.celerylib.tasks |
|
323 | celery.imports = kallithea.lib.celerylib.tasks | |
326 |
|
324 | celery.accept.content = pickle | ||
327 | celery.result.backend = amqp |
|
325 | celery.result.backend = amqp | |
328 | celery.result.dburi = amqp:// |
|
326 | celery.result.dburi = amqp:// | |
329 | celery.result.serialier = json |
|
327 | celery.result.serialier = json | |
@@ -332,11 +330,9 b' celery.result.serialier = json' | |||||
332 | #celery.amqp.task.result.expires = 18000 |
|
330 | #celery.amqp.task.result.expires = 18000 | |
333 |
|
331 | |||
334 | celeryd.concurrency = 2 |
|
332 | celeryd.concurrency = 2 | |
335 | #celeryd.log.file = celeryd.log |
|
|||
336 | celeryd.log.level = DEBUG |
|
|||
337 | celeryd.max.tasks.per.child = 1 |
|
333 | celeryd.max.tasks.per.child = 1 | |
338 |
|
334 | |||
339 | ## tasks will never be sent to the queue, but executed locally instead. |
|
335 | ## If true, tasks will never be sent to the queue, but executed locally instead. | |
340 | celery.always.eager = false |
|
336 | celery.always.eager = false | |
341 |
|
337 | |||
342 | #################################### |
|
338 | #################################### |
General Comments 0
You need to be logged in to leave comments.
Login now