| .. |
|
__init__.py
|
c02e51c067
Worker: autoreload should ignore not implemented pool.restart. Closes #2153
|
%!s(int64=11) %!d(string=hai) anos |
|
autoreload.py
|
a50d1cd549
Tests pass on PyPy
|
%!s(int64=12) %!d(string=hai) anos |
|
autoscale.py
|
fab0b11e54
Closes #2326 for master branch
|
%!s(int64=10) %!d(string=hai) anos |
|
components.py
|
b1a2b2592a
Embedded beat must set app for thread/process. Closes #2594
|
%!s(int64=10) %!d(string=hai) anos |
|
consumer.py
|
4f905dfd52
Use US spelling of cancelled -> canceled
|
%!s(int64=9) %!d(string=hai) anos |
|
control.py
|
9a642ee366
don't clobber other event types in enable_events.
|
%!s(int64=11) %!d(string=hai) anos |
|
heartbeat.py
|
610b1a7657
worker.heartbeat: Update 'interval' doc default to 2 seconds
|
%!s(int64=11) %!d(string=hai) anos |
|
job.py
|
d4e72df2a7
flakes
|
%!s(int64=10) %!d(string=hai) anos |
|
loops.py
|
ee88f6a429
Fix for drain_events when using Redis
|
%!s(int64=10) %!d(string=hai) anos |
|
pidbox.py
|
4f905dfd52
Use US spelling of cancelled -> canceled
|
%!s(int64=9) %!d(string=hai) anos |
|
state.py
|
a401d2ab24
[Prefork] Reset celery.worker.state after fork
|
%!s(int64=9) %!d(string=hai) anos |
|
strategy.py
|
cb806c7416
Optimization for #2358
|
%!s(int64=11) %!d(string=hai) anos |
Ask Solem
a401d2ab24
[Prefork] Reset celery.worker.state after fork