| .. |
|
__init__.py
|
a5f0251d60
WorkController now supports queues= argument which is a list like -Q
|
14 lat temu |
|
autoscale.py
|
8e90f8f42e
Fixes test failures. Closes #551
|
14 lat temu |
|
buckets.py
|
b01b81c60a
Use TokenBucket from kombu.utils.limits instead.
|
14 lat temu |
|
consumer.py
|
1515d94b39
Can now override the execution strategy for each task.
|
14 lat temu |
|
control.py
|
d8fd481d51
Merge branch 'master' into utc
|
14 lat temu |
|
heartbeat.py
|
641e838dd6
Cosmetics
|
14 lat temu |
|
job.py
|
789f53eb49
Optimizes TaskTrace
|
14 lat temu |
|
mediator.py
|
cf522ee855
Some small optimizations
|
14 lat temu |
|
state.py
|
641e838dd6
Cosmetics
|
14 lat temu |
|
strategy.py
|
1515d94b39
Can now override the execution strategy for each task.
|
14 lat temu |
Ask Solem
789f53eb49
Optimizes TaskTrace