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