| .. |
|
__init__.py
|
e3885e7dba
Move enable_forking to celery.concurrency.processes
|
13 gadi atpakaļ |
|
autoreload.py
|
8e11d7b11d
Don't use dict.keys/iterkeys
|
13 gadi atpakaļ |
|
autoscale.py
|
8dd5b4d7fd
renames worker.abstract -> worker.bootsteps
|
13 gadi atpakaļ |
|
bootsteps.py
|
8dd5b4d7fd
renames worker.abstract -> worker.bootsteps
|
13 gadi atpakaļ |
|
buckets.py
|
8e11d7b11d
Don't use dict.keys/iterkeys
|
13 gadi atpakaļ |
|
consumer.py
|
ba74b7e6e5
[ev] Now calls on_poll_empty (requires kombu master)
|
13 gadi atpakaļ |
|
control.py
|
8e11d7b11d
Don't use dict.keys/iterkeys
|
13 gadi atpakaļ |
|
heartbeat.py
|
566c4da7b4
Use ' instead of "
|
13 gadi atpakaļ |
|
hub.py
|
566c4da7b4
Use ' instead of "
|
13 gadi atpakaļ |
|
job.py
|
e5f647b9f3
task-failed event did not repr exception anymore
|
13 gadi atpakaļ |
|
mediator.py
|
bf09961d12
Revoking a task must also release the semaphore. Closes #877. Big thanks to @hynek
|
13 gadi atpakaļ |
|
state.py
|
4d4c9ba1d5
Envvar C_BENCH_EVERY alias to CELERY_BENCH_EVERY
|
13 gadi atpakaļ |
|
strategy.py
|
247674ceca
Small fixes
|
13 gadi atpakaļ |
Ask Solem
e5f647b9f3
task-failed event did not repr exception anymore