| .. |
|
control
|
aa389721b1
Revoked tasks now marked with state REVOKED, and result.get() will now raise TaskRevokedError.
|
%!s(int64=15) %!d(string=hai) anos |
|
__init__.py
|
5f9e0cae21
Added CELERYD_MAX_TASKS_PER_CHILD / --maxtasksperchild
|
%!s(int64=15) %!d(string=hai) anos |
|
buckets.py
|
4b28602c23
PEP8ify
|
%!s(int64=15) %!d(string=hai) anos |
|
controllers.py
|
c30bebe09d
Sleep only 0.2s not 1s after empty queue (round-trip time went from 0.03s to 0.01s, without hammering CPU)
|
%!s(int64=15) %!d(string=hai) anos |
|
heartbeat.py
|
85fb35af30
try: finally is available in 2.4, just not try: except: finally
|
%!s(int64=15) %!d(string=hai) anos |
|
job.py
|
da824caadc
TaskWrapper.execute now also respects acks_late
|
%!s(int64=15) %!d(string=hai) anos |
|
listener.py
|
f91ade4367
Events: repr complex objects sent as event fields.
|
%!s(int64=15) %!d(string=hai) anos |
|
pool.py
|
218dd421b7
tests: Now mocks the Pool
|
%!s(int64=15) %!d(string=hai) anos |
|
revoke.py
|
1c4a5fb044
Move documentation for celery.worker.revoke to the rst file.
|
%!s(int64=16) %!d(string=hai) anos |
|
scheduler.py
|
4b28602c23
PEP8ify
|
%!s(int64=15) %!d(string=hai) anos |
Ask Solem
218dd421b7
tests: Now mocks the Pool