 Ask Solem
|
8df76d0a5d
celeryd -Q option: Ability to specifiy list of queues to use, disabling other configured queues. Closes #78
|
vor 15 Jahren |
|
Ask Solem
|
159e4415c7
Django specific modules moved to the django-celery package.
|
vor 15 Jahren |
|
Ask Solem
|
98406f8e35
pyflakes
|
vor 15 Jahren |
|
Ask Solem
|
41bffe660d
Events: Added setting CELERY_EVENT_SERIALIZER with default "pickle".
|
vor 15 Jahren |
|
Ask Solem
|
6ab08ad905
Control reply queue should be non-durable, non-persistent and auto_delete
|
vor 15 Jahren |
|
Ask Solem
|
e7ca126fb3
celery.messaging: Added cosumer/publisher for control command reply queue.
|
vor 15 Jahren |
|
Ask Solem
|
ad8443eb2c
apply_async: Raise ValueError if task args is not a list, or kwargs is not a tuple. Closes #95. Thanks to TheAtilla.
|
vor 15 Jahren |
|
Ask Solem
|
1ca8fa2431
Handle message decode errors properly. Thanks to Jacob Burch.
|
vor 15 Jahren |
|
Ask Solem
|
012ca1239f
Added Task.delivery_mode / CELERY_DEFAULT_DELIVERY_MODE, with this you can configure tasks to be non-persistent. Closes #69.
|
vor 15 Jahren |
|
Ask Solem
|
635f711179
Optimization: Only declare a task exchange once for every process.
|
vor 15 Jahren |
|
Ask Solem
|
85fb35af30
try: finally is available in 2.4, just not try: except: finally
|
vor 15 Jahren |
 Jesper Noehr
|
998b9e1fcf
There, should've gotten most of core away from using finally.
|
vor 15 Jahren |
|
Ask Solem
|
db933ed0ad
Refactored .execute.apply_async: .messaging.TaskPublisher.send_task now
|
vor 15 Jahren |
|
Ask Solem
|
8abccbe361
get_consumer_set: Don't modify global QUEUE configuration
|
vor 15 Jahren |
|
Ask Solem
|
94de4a3d6a
PEP8ify + pyflakes
|
vor 16 Jahren |
|
Ask Solem
|
a9c1316b15
Fixed this really ugly bug: After renaming consumer routing_key to binding_key
|
vor 16 Jahren |
|
Ask Solem
|
3faf618af2
Make sure all queues are declared before publishing.
|
vor 16 Jahren |
|
Ask Solem
|
1da4812289
BroadcastConsumer: Needed unique queue name to be broadcast, so queue name generated using the current hostname.
|
vor 16 Jahren |
|
Ask Solem
|
26611b783f
Can now configure broadcast/event queue/exchange settings, and the amqp result backend exchange.
|
vor 16 Jahren |
|
Ask Solem
|
b1b2b1de52
Moved startup info related functions to celery.utils.info
|
vor 16 Jahren |
|
Ask Solem
|
890428d4c3
Finally: Configuration naming consistency. Old names deprecated in favor of:
|
vor 16 Jahren |
|
Ask Solem
|
ee79e3b466
Updated with new AMQP queue/exchange settings: http://wiki.github.com/ask/celery/rewriting-the-amqp-routing-options
|
vor 16 Jahren |
|
Ask Solem
|
248e77c138
Added broadcast() and rate_limit() remote control utilities + remote shutdown of workers.
|
vor 16 Jahren |
|
Ask Solem
|
3fa0d1bb12
Make with_connection a decorator
|
vor 16 Jahren |
|
Ask Solem
|
1b9c6fd28f
Missing import of celery.utils.noop
|
vor 16 Jahren |
|
Ask Solem
|
5772b2bc98
Get DjangoBrokerConnection from one place: celery.messaging.establish_connection
|
vor 16 Jahren |
|
Ask Solem
|
d4b6c00585
Merge branch 'events'
|
vor 16 Jahren |
|
Ask Solem
|
ddaec795c0
Remove the statistics thing (-S, celerystats etc) as it's being replaced by celerymon
|
vor 16 Jahren |
|
Ask Solem
|
396b5ba335
More work on celerymon
|
vor 16 Jahren |
|
Ask Solem
|
6b34bc5aee
Refactored API handlers and added new api: /api/revoke/task/$task_id
|
vor 16 Jahren |
