| .. |
|
control
|
1ab37bbf44
Use safe_repr to ensure repr doesn't crash the worker. Closes #298
|
14 years ago |
|
__init__.py
|
9b33d52043
Keep all queues for routing purposes when selecting queue subset for consumng. Closes #319. Thanks to marcinn
|
14 years ago |
|
autoscale.py
|
f85aaec9b1
Tests passing on Jython
|
15 years ago |
|
buckets.py
|
377f1cc358
Cosmetics
|
15 years ago |
|
consumer.py
|
58d12a0737
Removes left-over print statement
|
14 years ago |
|
controllers.py
|
f85aaec9b1
Tests passing on Jython
|
15 years ago |
|
heartbeat.py
|
e2f8a5cead
Now runs on Jython using -P threads
|
15 years ago |
|
job.py
|
4b370e563c
Propagate the taskset UUID from the message body to the task request.
|
14 years ago |
|
state.py
|
46a251ee4e
CELERY_BENCH envvar now enables benchmarking of time spent processing 1000 tasks
|
14 years ago |