.. |
consumer
|
c1fa9af097
Consumer does not shutdown properly when embedded in gevent application (#3746)
|
8 jaren geleden |
__init__.py
|
9ce1b1bf65
Cosmetics
|
9 jaren geleden |
autoscale.py
|
fca57b63f7
Revert "Removes autoscale option completely"
|
9 jaren geleden |
components.py
|
fca57b63f7
Revert "Removes autoscale option completely"
|
9 jaren geleden |
control.py
|
665c8842fc
Run CI on integration test suite
|
9 jaren geleden |
heartbeat.py
|
9ce1b1bf65
Cosmetics
|
9 jaren geleden |
loops.py
|
4d63867c82
prevent consuming queue before ready on startup (#3752)
|
8 jaren geleden |
pidbox.py
|
9b6d03f032
Worker: Fixes heartbeats for gevent/eventlet. Closes #3649
|
8 jaren geleden |
request.py
|
64a02078fa
Worker: Request.info should not contain message body, makes sure JSON serializable. Closes #3667
|
8 jaren geleden |
state.py
|
4834fdad77
Make bytestrings into str for shelve (#3644)
|
8 jaren geleden |
strategy.py
|
eac96241d2
Fix task ETA issues when timezone is defined in configuration (#3867)
|
8 jaren geleden |
worker.py
|
31b5ce229c
flakes
|
9 jaren geleden |