 Ask Solem
|
0dbdc5de4d
94% total coverage
|
15 éve |
|
Ask Solem
|
2a4659a067
itertools.chain.from_iterable new in Py2.6
|
15 éve |
|
Ask Solem
|
d8f853189b
celery.buckets: Use collections.deque instead of Queue for buffer, as it doesn't have to be thread safe.
|
16 éve |
|
Ask Solem
|
4b28602c23
PEP8ify
|
16 éve |
|
Ask Solem
|
3ff2e37963
Moved date and time related utility functions to celery.utils.timeutils
|
16 éve |
|
Ask Solem
|
f98fbbf387
celery.utils.compat.izip_longest: Compat version of itertools.izip_longest (Py2.6+)
|
16 éve |
|
Ask Solem
|
00524d6b35
The Mediator thread should not block for more than 1 second.
|
16 éve |
|
Ask Solem
|
a270422862
New remote control command: dump_reserved: Dump currently waiting tasks
|
16 éve |
|
Ask Solem
|
8e3c23408a
Refactored some of the isintance mess with TokenBucket Queue vs TokenBucketQueue.
|
16 éve |
|
Ask Solem
|
3049f338eb
remote-control rate limits: Forgot to update the buckets. See Issue #98.
|
16 éve |
|
Ask Solem
|
a3c2c539ef
pyflakes
|
16 éve |
|
Ask Solem
|
1f1ffffc59
TaskBucket buckets can be either Queue or TokenBucketQueue, so clear accordingly.
|
16 éve |
|
Ask Solem
|
a5224448fb
Tests now passes on Python 2.5
|
16 éve |
|
Ask Solem
|
e37740255c
Clear internal queues if connection reset.
|
16 éve |
|
Ask Solem
|
4cc234159a
Pyflakes
|
16 éve |
|
Ask Solem
|
5a995ce483
Compat implementation of all(), any() and collections.defaultdict
|
16 éve |
|
Ask Solem
|
0d5d2b2a02
Replace 'a if p else b' with 'p and a or b' for Python 2.4 compatibility.
|
16 éve |
|
Ask Solem
|
28f47d1fc3
Use carrot.utils.partition/rpartition for Python 2.4 compatibility.
|
16 éve |
|
Ask Solem
|
4041250e89
Some documentation and nitpicking.
|
16 éve |
|
Ask Solem
|
d663c1b615
Automatically add buckets for task types not registered at init. Thanks thruflo
|
16 éve |
|
Ask Solem
|
79cd3fb5b1
Allow setting the Tasks queue type for the rate limiter, so it can be set to LifoQueue
|
16 éve |
|
Ask Solem
|
c6886cb371
All tests passing!
|
16 éve |
|
Ask Solem
|
0714347bf7
Renamed celery.buckets -> celery.worker.buckets
|
16 éve |
