 Ask Solem
|
8cf86b89be
Forgot to emit deprectation warning if CELERY_AMQP_CONSUMER_QUEUE present.
|
пре 15 година |
|
Ask Solem
|
447ed8e1cc
Be compatible with previous queue configuration scheme, but raise DeprecationWarnings if any of the old settings is set.
|
пре 15 година |
|
Ask Solem
|
ce3a22a505
apply_async: Pass exchange argument on to task.get_publisher
|
пре 15 година |
|
Ask Solem
|
d1fb7dda7c
scheduler wake-up debug message was not working properly because repeat silencer was local to on_iteration.
|
пре 15 година |
|
Ask Solem
|
b9e9fb4257
Use task.get_publisher with apply_async so the exchange is configured properly.
|
пре 15 година |
|
Ask Solem
|
ee79e3b466
Updated with new AMQP queue/exchange settings: http://wiki.github.com/ask/celery/rewriting-the-amqp-routing-options
|
пре 15 година |
|
Ask Solem
|
243b29e729
Also load CELERY_IMPORTS when running with django (as documented)
|
пре 15 година |
|
Ask Solem
|
f65ffc1793
Move task tracing to celery.execute.trace
|
пре 15 година |
|
Ask Solem
|
4082dee3de
exceptions.NotRegistered now inherits from keyerror, and TaskRegistry.__getitem__+pop raises NotRegistered instead of KeyError.
|
пре 15 година |
|
Ask Solem
|
ba969f807d
Use mattrgetter in apply_async()
|
пре 15 година |
|
Ask Solem
|
a952bdf259
No need to use inline imports for ALWAYS_EAGER
|
пре 15 година |
|
Ask Solem
|
5e40be713e
Big celery.conf clean-up
|
пре 15 година |
|
Ask Solem
|
8d826bdb28
Added autodoc rst for celery.task.control to User Reference
|
пре 15 година |
|
Ask Solem
|
e044fd32e9
revoke is no longer imported by celery.task, import from celery.task.control instead.
|
пре 15 година |
|
Ask Solem
|
248e77c138
Added broadcast() and rate_limit() remote control utilities + remote shutdown of workers.
|
пре 15 година |
|
Ask Solem
|
3fa0d1bb12
Make with_connection a decorator
|
пре 15 година |
|
Ask Solem
|
b4b89d94a2
More docstrings, Reorder imports and other cosmetic changes
|
пре 15 година |
|
Ask Solem
|
3de94f6996
Updated billiard dependency to >=0.2.1
|
пре 15 година |
|
Ask Solem
|
3f4e261d68
Move revoke() + discard_all() to celery.task.control
|
пре 15 година |
|
Ask Solem
|
819920bc8e
TaskSet.run renamed to TaskSet.apply_async and is pending deprecation for v1.2.0. Closes #58.
|
пре 15 година |
|
Ask Solem
|
5fac4f99c7
Split eager run in TaskSet.run into TaskSet.run_eager
|
пре 15 година |
|
Ask Solem
|
57134038b5
Don't evaluate PeriodicTask.run_every, use hasattr instead, in case implemented by property.
|
пре 15 година |
|
Ask Solem
|
c6a4a209e5
Add some missing docstrings for celery.task.base
|
пре 15 година |
|
Ask Solem
|
c12ad5cb28
Add the ability to turn off automatic registration of tasks by setting Task.autoregister = False.
|
пре 15 година |
 Jerzy Kozera
|
0e4e001dd5
Fixed race condition in storing task task in DB
|
пре 15 година |
|
Ask Solem
|
5a995ce483
Compat implementation of all(), any() and collections.defaultdict
|
пре 15 година |
|
Ask Solem
|
092db37745
Removed unused import of contextmanager
|
пре 15 година |
|
Ask Solem
|
360604811e
Forgot another instance of functools.partial
|
пре 15 година |
|
Ask Solem
|
0d5d2b2a02
Replace 'a if p else b' with 'p and a or b' for Python 2.4 compatibility.
|
пре 15 година |
|
Ask Solem
|
28f47d1fc3
Use carrot.utils.partition/rpartition for Python 2.4 compatibility.
|
пре 15 година |
