| .. |
|
__init__.py
|
73a7d10b56
Only start timer threads when needed
|
13 vuotta sitten |
|
autoscale.py
|
8e90f8f42e
Fixes test failures. Closes #551
|
14 vuotta sitten |
|
buckets.py
|
b01b81c60a
Use TokenBucket from kombu.utils.limits instead.
|
14 vuotta sitten |
|
consumer.py
|
a9d898ddef
Tests passing
|
13 vuotta sitten |
|
control.py
|
d8fd481d51
Merge branch 'master' into utc
|
14 vuotta sitten |
|
heartbeat.py
|
73a7d10b56
Only start timer threads when needed
|
13 vuotta sitten |
|
job.py
|
a9d898ddef
Tests passing
|
13 vuotta sitten |
|
mediator.py
|
cf522ee855
Some small optimizations
|
14 vuotta sitten |
|
state.py
|
a9d898ddef
Tests passing
|
13 vuotta sitten |
|
strategy.py
|
29ad3bde87
Optimization: Now at 10.000 tasks/s with librabbitmq
|
13 vuotta sitten |
Ask Solem
a9d898ddef
Tests passing