 Ask Solem
|
fb4ab44b7b
apply_async: Added the ability to retry publishing the task message in the event of connection loss or failure.
|
15 éve |
|
Ask Solem
|
a5e15c7ecd
AMQP Result backend: Use connection.ensure when retrying publishing results, and don't create a new channel for every publish
|
15 éve |
|
Ask Solem
|
0d61ea5c26
Don't explicitly delete the queue but rather leave that up to the broker and CELERY_AMQP_TASK_RESULT_EXPIRES. Closes #278
|
15 éve |
 jpellerin
|
19e396d629
Updated amqp backend to pass queue arguments to Queue()
|
15 éve |
|
Ask Solem
|
dfbac4a6f9
TaskSetResult.join + AsyncResult.wait improvements.
|
15 éve |
|
Ask Solem
|
18d2b79f76
99% Coverage for celery.backends.amqp
|
15 éve |
|
Ask Solem
|
331166fa22
Use @cached_property
|
15 éve |
|
Ask Solem
|
a3ab0b4855
Py2.4: Cannot yield inside try: finally: block. :(
|
15 éve |
|
Ask Solem
|
e1731a5204
AMQP Result Backend: Queue must be declared before polling result. Thanks to bmbouter
|
15 éve |
 Ask Solem
|
eb81270dbe
AMQP result backend: Fixed typo channel.release -> channel.close
|
15 éve |
|
Ask Solem
|
1b8e2777d1
Catch channel errors when deleting result queue with if_empty=True
|
15 éve |
|
Ask Solem
|
785ab7925a
PEP8ify + pyflakes
|
15 éve |
|
Ask Solem
|
a083980ab6
Added TaskSetResult.iter_native: Native way to iterate on multiple results as they finish
|
15 éve |
|
Ask Solem
|
060b266866
AMQP result backend now uses a connection pool (new setting: CELERY_AMQP_TASK_RESULT_CONNECTION_MAX). This means results can now be sent when running in eventlet/gevent
|
15 éve |
|
Ask Solem
|
98f82ed794
AMQP result backend: Needs to strip '-'s from the task id for backward compatibility
|
15 éve |
|
Ask Solem
|
da6dc4bb4c
Merged branch join_native: TaskSetResult.join_native, uses backend-optimized solution to retrieve results for more than one task
|
15 éve |
|
Ask Solem
|
c4d723dfcb
Merge branch 'master' into kombu2
|
15 éve |
|
Ask Solem
|
ffe24d5ddd
Used internal interface for queue_delete
|
15 éve |
 Piotr Sikora
|
9c4e544629
Remove empty queue after AMQP result is received and make sure that it won't be re-created by using cache.
|
15 éve |
|
Ask Solem
|
df2184a794
AMQP result backend now using Kombu
|
15 éve |
|
Ask Solem
|
dbe832f744
Can now configure the apps main module name, used to autogenerate the module name if '__main__'
|
15 éve |
|
Ask Solem
|
5c2f636a76
Fixed some broken tests
|
15 éve |
|
Ask Solem
|
a3bd35c653
AMQP Result Backend: Enable auto_delete for the result queues again
|
15 éve |
|
Ask Solem
|
2a31555926
AMQP Result backend: Fixed ugly bug with result.get() if CELERY_TRACK_STARTED=True
|
15 éve |
|
Ask Solem
|
b470ecca1c
queue_declare argument x-expires must be a signed-int, or long describing the expiry time in milliseconds.
|
15 éve |
|
Ask Solem
|
6d7d4b4453
AMQP Backend: Support the x-expires argument for queues (using the CELERY_AMQP_TASK_RESULT_EXPIRES setting).
|
15 éve |
|
Ask Solem
|
a65b16d477
celery.messaging is now Celery().amqp
|
15 éve |
|
Ask Solem
|
b442d34c8e
Global settings removed. Still a little bit of refactoring to be done, but the tests passes now.
|
15 éve |
|
Ask Solem
|
5ae8d034e7
AMQP result backend: Set auto_delete=False again, as it seemed to introduce some subtle race conditions
|
15 éve |
|
Ask Solem
|
eec3714374
AMQP backend: Retry sending results
|
15 éve |
