| .. |
|
__init__.py
|
5ef7a652aa
added worker shutdown event support
|
13 anni fa |
|
autoreload.py
|
692c134633
Fixes autoreloader to work on non-top-level modules. Closes #823
|
13 anni fa |
|
autoscale.py
|
8dd5b4d7fd
renames worker.abstract -> worker.bootsteps
|
13 anni fa |
|
bootsteps.py
|
8dd5b4d7fd
renames worker.abstract -> worker.bootsteps
|
13 anni fa |
|
buckets.py
|
566c4da7b4
Use ' instead of "
|
13 anni fa |
|
consumer.py
|
0cf8045b54
add_consumer command now uses queue config from CELERY_QUEUES if it exists
|
12 anni fa |
|
control.py
|
24071a88a5
Adds Consumer.add_task_queue + cancel_task_queue
|
12 anni fa |
|
heartbeat.py
|
566c4da7b4
Use ' instead of "
|
13 anni fa |
|
hub.py
|
566c4da7b4
Use ' instead of "
|
13 anni fa |
|
job.py
|
79360903f4
ack retry after event sent
|
13 anni fa |
|
mediator.py
|
247674ceca
Small fixes
|
13 anni fa |
|
state.py
|
4d4c9ba1d5
Envvar C_BENCH_EVERY alias to CELERY_BENCH_EVERY
|
12 anni fa |
|
strategy.py
|
247674ceca
Small fixes
|
13 anni fa |
Ask Solem
0cf8045b54
add_consumer command now uses queue config from CELERY_QUEUES if it exists